apache / apache/pekko

Feature Request: Add Flow#transform method?

Open
#1,453 0 comments 1 reaction 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.