You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Disposabled = Mono.fromFuture(future) // source is fn
.flatMap() // flat map can not fuse since the source is just push based observable
.subscribe();
// 5 sec waitd.dispose() // after some time
Disposabled = Mono.fromFuture(future)
.cache() // can be represented as a queue
.flatMap() // flat map fuses with the source and treat it as a queue
.subscribe();
// 5 sec waitd.dispose() // after some time
ASYNC FUSION (makes no sense, just brings redundancy)
Disposabled = Mono.fromCallable(future) // source is fn
.flatMap() // flat map fuses with the source is callable
.subscribe();
// 5 sec waitd.dispose() // after some time
Callable macro fusion (a.k.a MONO SYNC FUSION) (means value is generated synchronously via function call or scalar)
Sync fusion can be a nice improvement for the reworked lazy mono for scenarios where the source is static data source
follow up for #3081
The text was updated successfully, but these errors were encountered: