Я не могу выяснить, как использовать Flowable с помощью subscribepublishes (mqtt5subscribe) Метод клиента hivemq rx. Он возвращает Flowable с помощью , который удерживает Flowable с опубликованными сообщениями. Flowable с помощью также удерживает один с результатом подписки. Подписка и обработка сообщений находятся в середине большого трубопровода.
Подробнее здесь: https://stackoverflow.com/questions/795 ... hes-method
