Feature Request: Add Flow#transform method?
Open
t:stream
- Dominant language
- Scala
- Stars
- 1.6k
- Forks
- 211
- Avg merge
- 1d 6h
- Merged PRs (30d)
- 89
Description
Motivation:
Using an inline `transform` method can get more fluent code as `Flux`.
When using reactor-core 's `Flux`, we have something like:
```java
sink.asFlux()
.onBackpressureBuffer()
.transform(new MsgTransformer())
.subscribe(msgs -> {
... }
```
And the `transform` method is just a syntax sugar:
```java
public final Flux transform(Function, ? extends Publisher> transformer) {
if (Hooks.DETECT_CONTEXT_LOSS) {
transformer = new ContextTrackingFunctionWrapper(transformer);
}
return onAssembly(from(transformer.apply(this)));
}
```
WDYT?
Result:
More fluent code.
Contributor guide
Assessment
This issue has not been assessed yet.