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

Merge pull request #21186 from agolubev/21049-gaps-in-stages-overview-doc-agolubev

Browse source 
=str 21049 gaps in Source/Sink sections of stages-overview documentation
This commit is contained in:
Patrik Nordwall 2016-08-23 12:08:38 +02:00 • committed by GitHub
commit 7f2b6f8b54
2 changed files with 35 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

17
akka-docs/rst/java/stream/stages-overview.rst
View file

@ -323,6 +323,23 @@ Invoke a callback when the stream has completed or failed.
**backpressures** never
lazyInit
^^^^^^^^
Invoke sinkFactory function to create a real sink upon receiving the first element. Internal ``Sink`` will not be created if there are no elements,
because of completion or error. `fallback` will be invoked if there was no elements and completed is received from upstream.
**cancels** never
**backpressures** when initialized and when created sink backpressures
queue
^^^^^
Materialize a ``SinkQueue`` that can be pulled to trigger demand through the sink. The queue contains
a buffer in case stream emitting elements faster than queue pulling them.
**cancels** when ``SinkQueue.cancel`` is called
**backpressures** when buffer has some space
fold
^^^^