Почему не использую реактивные стримы #конкурс
1) Есть несколько реализаций реактивных стримов, которые реализуют иногда достаточно похожие вещи разными способами. Вот если захочу написать свой паблишер данных из массива, как его написать так же как
FromArrayPublisher из ServiceTalk или
ObservableFromArray из RxJava или
FluxArray из Reactor или как в
RangePublisher из примеров ReactiveStreamsJvm?
Или например, если есть библиотека, к которой хочется написать реактивный коннектор? Как это сделать? Каким из множества способов?
2) Если не хватает какого-то оператора, а он есть в соседней реактивной бибилотеке, как их связать? Как например взять оператор из RxJava и присоединить его в паблишеру из Reactor? Если все таки делать это, может получится так, что придется поддерживать интеграции с несколькими реактивными библиотеками как в микронавте -
https://i.imgur.com/u6INXfn.png 3) У каждого есть модуль для работы с Netty например, какой из них лучший?
ServiceTaslk - servicetalk-transport-netty, RxJava - RxNetty, ProjectReactor - reactor-netty. Нужно измерить? Как? Ведь не получится их проверить, не притащив их всю платформу под ними. Можно ли использовать RxNetty и reactor-core вместе?