We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Motivation:
Using an inline transform method can get more fluent code as Flux. When using reactor-core 's Flux, we have something like:
transform
Flux
sink.asFlux() .onBackpressureBuffer() .transform(new MsgTransformer()) .subscribe(msgs -> { ... }
And the transform method is just a syntax sugar:
public final <V> Flux<V> transform(Function<? super Flux<T>, ? extends Publisher<V>> transformer) { if (Hooks.DETECT_CONTEXT_LOSS) { transformer = new ContextTrackingFunctionWrapper(transformer); } return onAssembly(from(transformer.apply(this))); }
WDYT?
Result: More fluent code.
The text was updated successfully, but these errors were encountered:
No branches or pull requests
Motivation:
Using an inline
transform
method can get more fluent code asFlux
.When using reactor-core 's
Flux
, we have something like:And the
transform
method is just a syntax sugar:WDYT?
Result:
More fluent code.
The text was updated successfully, but these errors were encountered: