raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Cross-references to/from ref-docs vs operator docs (#28788)

Browse source
This commit is contained in:
Ignasi Marimon-Clos 2020-03-24 14:47:03 +01:00 • committed by GitHub
parent 4b782e54b8
commit 04396d9c30
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-docs/src/main/paradox/stream/operators/Source-or-Flow/conflate.md
View file

@ -26,7 +26,9 @@ Scala
Java Java
: @@snip [SourceOrFlow.java](/akka-docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java) { #conflate } : @@snip [SourceOrFlow.java](/akka-docs/src/test/java/jdocs/stream/operators/SourceOrFlow.java) { #conflate }
If downstream is slower the elements is conflated by summing them. This means that upstream can continue producing elements while downstream is applying backpressure. For example: downstream is backpressuring while 1, 10 and 100 arrives from upstream, then backpressure stops and the conflated 111 is emitted downstream. If downstream is slower the elements are conflated by summing them. This means that upstream can continue producing elements while downstream is applying backpressure. For example: downstream is backpressuring while 1, 10 and 100 arrives from upstream, then backpressure stops and the conflated 111 is emitted downstream.
See @ref:[Rate transformation](../../stream-rate.md#rate-transformation) for more information and examples.
## Reactive Streams semantics ## Reactive Streams semantics

2
akka-docs/src/main/paradox/stream/operators/Source-or-Flow/conflateWithSeed.md
View file

@ -36,6 +36,8 @@ You may want to use this operation for example to apply an average operation on
while the downstream backpressures. This allows us to keep processing upstream elements, and give an average while the downstream backpressures. This allows us to keep processing upstream elements, and give an average
number to the downstream once it is ready to process the next one. number to the downstream once it is ready to process the next one.
See @ref:[Rate transformation](../../stream-rate.md#rate-transformation) for more information and examples.
## Reactive Streams semantics ## Reactive Streams semantics
@@@div { .callout } @@@div { .callout }

3
akka-docs/src/main/paradox/stream/stream-rate.md
View file

@ -207,6 +207,9 @@ Scala
Java Java
: @@snip [RateTransformationDocTest.java](/akka-docs/src/test/java/jdocs/stream/RateTransformationDocTest.java) { #conflate-sample } : @@snip [RateTransformationDocTest.java](/akka-docs/src/test/java/jdocs/stream/RateTransformationDocTest.java) { #conflate-sample }
See also @ref:[`conflate`](operators/Source-or-Flow/conflate.md) and @ref:[conflateWithSeed`](operators/Source-or-Flow/conflateWithSeed.md) for more information and examples.
### Understanding extrapolate and expand ### Understanding extrapolate and expand
Now we will discuss two operators, `extrapolate` and `expand`, helping to deal with slow producers that are unable to keep Now we will discuss two operators, `extrapolate` and `expand`, helping to deal with slow producers that are unable to keep