Reactive-Streams-Commons Fusion Matrix

First \ Second CombineLatest - inner ConcatMap Distinct DistinctFuseable DistinctUntilChanged Filter FilterFuseable FlatMap FlatMap - inner FlattenIterable Map MapFuseable Merge - inner ObserveOn Peek PeekFuseable Publish SkipWhile SubscribeOn Take TakeFuseable Using - inner Zip - inner
Aggregate Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
All Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Any Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Array Unfuseable Sync Sync
Conditional
Sync
Conditional
Conditional Sync
Conditional
Sync
Conditional
Unfuseable Sync Sync Sync
Conditional
Sync
Conditional
Sync Sync Conditional Sync
Conditional
Sync Conditional Unfuseable Sync
Conditional
Sync
Conditional
Sync
Conditional
Sync
AsyncProcessor Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Callable Scalar Async Async Async Unfuseable Async Async Scalar Scalar
Async
Scalar
Async
Async Async Scalar
Async
Scalar
Async
Unfuseable Async Async Unfuseable Scalar Async Async Async Scalar
Async
CallableSubscribeOn Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Unfuseable Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Collect Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
CombineLatest Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
CompletableFuture Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Count Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Distinct Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Sync
Async
Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
DistinctFuseable Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Sync
Async
Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
DistinctUntilChanged Unfuseable Unfuseable Conditional Conditional Conditional Conditional Conditional Unfuseable Unfuseable Unfuseable Conditional Conditional Unfuseable Unfuseable Conditional Conditional Unfuseable Conditional Unfuseable Conditional Conditional Conditional Unfuseable
ElementAt Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Empty Scalar Unfuseable Unfuseable Unfuseable Unfuseable Unfuseable Unfuseable Scalar Scalar Scalar Unfuseable Unfuseable Scalar Scalar Unfuseable Unfuseable Unfuseable Unfuseable Scalar Unfuseable Unfuseable Unfuseable Scalar
Filter Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Unfuseable Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
FilterFuseable Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Unfuseable Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
FlattenIterable Unfuseable Sync Sync Sync Unfuseable Sync Sync Unfuseable Sync Sync Sync Sync Sync Sync Unfuseable Sync Sync Unfuseable Unfuseable Sync Sync Sync Sync
Future Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Generate Unfuseable Sync Sync Sync Unfuseable Sync Sync Unfuseable Sync Sync Sync Sync Sync Unfuseable Unfuseable Sync Sync Unfuseable Unfuseable Sync Sync Sync Sync
GroupBy Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
GroupBy - inner Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
HasElements Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Iterable Unfuseable Sync Sync
Conditional
Sync
Conditional
Conditional Sync
Conditional
Sync
Conditional
Unfuseable Sync Sync Sync
Conditional
Sync
Conditional
Sync Sync Conditional Sync
Conditional
Sync Conditional Unfuseable Sync
Conditional
Sync
Conditional
Sync
Conditional
Sync
Just Scalar Sync Sync Sync Unfuseable Sync Sync Scalar Scalar
Sync
Scalar
Sync
Sync Sync Scalar
Sync
Scalar
Sync
Unfuseable Sync Sync Unfuseable Scalar Sync Sync Sync Scalar
Sync
Map Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Unfuseable Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
MapFuseable Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Unfuseable Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
ObserveOn Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Peek Unfuseable Unfuseable Conditional Conditional Conditional Conditional Conditional Unfuseable Unfuseable Unfuseable Conditional Conditional Unfuseable Unfuseable Conditional Conditional Unfuseable Conditional Unfuseable Conditional Conditional Conditional Unfuseable
PeekFuseable Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Sync
Async
Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Publish Unfuseable Sync
Async
Sync
Async
Sync
Async
Unfuseable Sync
Async
Sync
Async
Unfuseable Sync
Async
Sync
Async
Sync
Async
Sync
Async
Sync
Async
Sync
Async
Unfuseable Sync
Async
Sync
Async
Unfuseable Unfuseable Sync
Async
Sync
Async
Sync
Async
Sync
Async
Range Unfuseable Sync Sync
Conditional
Sync
Conditional
Conditional Sync
Conditional
Sync
Conditional
Unfuseable Sync Sync Sync
Conditional
Sync
Conditional
Sync Sync Conditional Sync
Conditional
Sync Conditional Unfuseable Sync
Conditional
Sync
Conditional
Sync
Conditional
Sync
Reduce Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
ReplayProcessor Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Single Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
SkipWhile Unfuseable Unfuseable Conditional Conditional Conditional Conditional Conditional Unfuseable Unfuseable Unfuseable Conditional Conditional Unfuseable Unfuseable Conditional Conditional Unfuseable Conditional Unfuseable Conditional Conditional Conditional Unfuseable
Stream Unfuseable Sync Sync
Conditional
Sync
Conditional
Conditional Sync
Conditional
Sync
Conditional
Unfuseable Sync Sync Sync
Conditional
Sync
Conditional
Sync Sync Conditional Sync
Conditional
Sync Conditional Unfuseable Sync
Conditional
Sync
Conditional
Sync
Conditional
Sync
StreamCollector Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
SubscribeOn Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
SubscribeOnValue Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Take Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Sync
Async
Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
TakeFuseable Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Sync
Async
Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
TakeLast Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
TakeLastOne Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
UnicastProcessor Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
Using Unfuseable Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Conditional Sync
Async
Conditional
Sync
Async
Conditional
Unfuseable Sync
Async
Sync
Async
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Sync
Async
Conditional Sync
Async
Conditional
Sync
Async
Conditional Unfuseable Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Conditional
Sync
Async
Window - inner Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async
WindowBatch - inner Unfuseable Async Async Async Unfuseable Async Async Unfuseable Async Async Async Async Async Async Unfuseable Async Async Unfuseable Unfuseable Async Async Async Async