将 RxJava 运算符打包为处理器对象的最佳方法是什么？
我正在为 OpenLiberty 中的 MicroProfile Reactive Streams 实现编写一些简单的测试用例。
我在类路径上有 RxJava，并且想探索将 RxJava 运算符打包为处理器对象，然后我可以将其嵌入到我自己的框架的单元测试中。
与此处类似： https ://github.com/OpenLiberty/open-liberty/pull/6617/files#r259264238
我想问一些更有经验的 RxJava 程序员最好的选择是什么？
从一个反应式流框架中打包一个“缺失”的运算符并将其嵌入到另一个框架中似乎是一件不寻常的事情，但我已经看到其他系统混合了多个框架（例如 reator 和 rxjava）并作为新框架，我们目前内置了一组基本的操作符。因此，从经验中获得意见而不是我破解 Heath Robinson 的装置可能会很有趣。
戈登。