diff --git a/akka-docs/rst/java/stream/stages-overview.rst b/akka-docs/rst/java/stream/stages-overview.rst index 053fe2c77b..812aa74bdc 100644 --- a/akka-docs/rst/java/stream/stages-overview.rst +++ b/akka-docs/rst/java/stream/stages-overview.rst @@ -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 ^^^^ diff --git a/akka-docs/rst/scala/stream/stages-overview.rst b/akka-docs/rst/scala/stream/stages-overview.rst index d5f10f0d52..b52922a31d 100644 --- a/akka-docs/rst/scala/stream/stages-overview.rst +++ b/akka-docs/rst/scala/stream/stages-overview.rst @@ -168,7 +168,7 @@ Wrap any resource that can be opened, queried for next element (in a blocking wa **completes** when read function returns ``None`` -unfoldAsyncResource +unfoldResourceAsync ^^^^^^^^^^^^^^^^^^^ Wrap any resource that can be opened, queried for next element (in a blocking way) and closed using three distinct functions into a source. Functions return ``Future`` to achieve asynchronous processing @@ -312,6 +312,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 ^^^^