Class SourceOperations
TBD
Inherited Members
Namespace: Akka.Streams.Dsl
Assembly: Akka.Streams.dll
Syntax
public static class SourceOperationsMethods
| Edit this page View SourceAggregateAsync<TOut1, TOut2, TMat>(Source<TOut1, TMat>, TOut2, Func<TOut2, TOut1, Task<TOut2>>)
Similar to Aggregate<TOut1, TOut2, TMat>(Source<TOut1, TMat>, TOut2, Func<TOut2, TOut1, TOut2>) but with an asynchronous function. Applies the given function towards its current and next value, yielding the next current value.
If the function fold returns a failure and the supervision decision is
Restart current value starts at zero again
the stream will continue.
Emits when upstream completes
Backpressures when downstream backpressures
Completes when upstream completes
Cancels when downstream cancels
Aggregate<TOut1, TOut2, TMat>(Source<TOut1, TMat>, TOut2, Func<TOut2, TOut1, TOut2>)
Declaration
public static Source<TOut2, TMat> AggregateAsync<TOut1, TOut2, TMat>(this Source<TOut1, TMat> flow, TOut2 zero, Func<TOut2, TOut1, Task<TOut2>> fold)Parameters
| Type | Name | Description |
|---|---|---|
| Source<TOut1, TMat> | flow | TBD |
| TOut2 | zero | TBD |
| Func<TOut2, TOut1, Task<TOut2>> | fold | TBD |
Returns
| Type | Description |
|---|---|
| Source<TOut2, TMat> | TBD |
Type Parameters
| Name | Description |
|---|---|
| TOut1 | TBD |
| TOut2 | TBD |
| TMat | TBD |
Aggregate<TOut1, TOut2, TMat>(Source<TOut1, TMat>, TOut2, Func<TOut2, TOut1, TOut2>)
Similar to Scan<TOut1, TOut2, TMat>(Source<TOut1, TMat>, TOut2, Func<TOut2, TOut1, TOut2>) but only emits its result when the upstream completes,
after which it also completes. Applies the given function fold towards its current and next value,
yielding the next current value.
If the function fold throws an exception and the supervision decision is
Restart current value starts at zero again
the stream will continue.
Emits when upstream completes