Я решил это по-другому.Поскольку я использую MQTT для веб-сокетов, а не для самих веб-сокетов, модуль ngx-mqtt уже создал наблюдаемые для подписки на каналы.Вопрос останется в сети, потому что эта тема сочетает в себе наблюдаемые и обещания, и я знаю, что больше людей будут бороться из-за этого.