Каков наилучший способ упаковки оператора RxJava в качестве объекта Processor?
Я пишу несколько простых тестовых примеров для реализации MicroProfile Reactive Streams в OpenLiberty.
У меня есть RxJava на пути к классам, и я хочу изучить упаковку оператора RxJava в качестве объекта Processor, который я затем могу вставить в модульные тесты моей собственной платформы.
Аналогично здесь: https://github.com/OpenLiberty/open-liberty/pull/6617/files#r259264238
Я хотел спросить у более опытных программистов на RxJava, какой вариант лучше?
Упаковка «пропущенного» оператора из одной среды реактивных потоков и встраивание его в другую может показаться необычным деломно я видел другие системы , которые имеют более одного фреймворка (такого как reator и rxjava) в миксе, и в качестве нового фреймворка у нас в настоящее время встроен базовый набор операторов. Так что может быть интереснополучить мнение на основе опыта, а не я взломать хитрость хитрости Робинсон.
Гордон.