| SinkAggregateAsyncTIn, TOut Method |
A
SinkTIn, TMat that will invoke the given asynchronous function for every received element,
giving it its previous output (or the given
zero value) and the element as input.
The returned
Task will be completed with value of the final
function evaluation when the input stream ends, or completed with "Failure"
if there is a failure signaled in the stream.
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax public static Sink<TIn, Task<TOut>> AggregateAsync<TIn, TOut>(
TOut zero,
Func<TOut, TIn, Task<TOut>> aggregate
)
static member AggregateAsync :
zero : 'TOut *
aggregate : Func<'TOut, 'TIn, Task<'TOut>> -> Sink<'TIn, Task<'TOut>>
Parameters
- zero
- Type: TOut
TBD - aggregate
- Type: SystemFuncTOut, TIn, TaskTOut
TBD
Type Parameters
- TIn
- TBD
- TOut
- TBD
Return Value
Type:
SinkTIn,
TaskTOutTBD
See Also