Пытаюсь использовать эту библиотеку в версии 0.4.1 из Maven Central в связке с Project Reactor.
Метод StreamingContext.getEventPublisher() возвращает стандарный интерфейс Publisher из reactive-streams.
Пытаюсь завернуть его во Flux:
но сигналы не доходят до subscriber'а в лямбде. Подозреваю, что и с RxJava тоже не заработает.
Покопавшись в коде пришел к выводу, что это происходит из-за бага, исправленного этим коммитом (сборка из репозитория работает ожидаемо). Однако он не попал в версию, которая сейчас выложена на Maven Central и новых релизов с марта также не было. Считаю, что необходимо как можно быстрее выложить новую версию в репозиторий.
Пытаюсь использовать эту библиотеку в версии 0.4.1 из Maven Central в связке с Project Reactor. Метод
StreamingContext.getEventPublisher()возвращает стандарный интерфейсPublisherиз reactive-streams. Пытаюсь завернуть его во Flux:но сигналы не доходят до subscriber'а в лямбде. Подозреваю, что и с RxJava тоже не заработает.
Покопавшись в коде пришел к выводу, что это происходит из-за бага, исправленного этим коммитом (сборка из репозитория работает ожидаемо). Однако он не попал в версию, которая сейчас выложена на Maven Central и новых релизов с марта также не было. Считаю, что необходимо как можно быстрее выложить новую версию в репозиторий.