 | FlowOperationsLimitTIn, TOut, TMat Method |
Ensure stream boundedness by limiting the number of elements from upstream.
If the number of incoming elements exceeds max, it will signal
upstream failure StreamLimitReachedException downstream.
Due to input buffering some elements may have been
requested from upstream publishers that will then not be processed downstream
of this step.
The stream will be completed without producing any elements if max is zero
or negative.
Emits when the specified number of elements to take has not yet been reached
Backpressures when downstream backpressuresCompletes when the defined number of elements has been taken or upstream completes
Cancels when the defined number of elements has been taken or downstream cancelsNamespace: Akka.Streams.Dsl
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntaxpublic static Flow<TIn, TOut, TMat> Limit<TIn, TOut, TMat>( this Flow<TIn, TOut, TMat> flow, long max )
Parameters
- flow
- Type: Akka.Streams.DslFlowTIn, TOut, TMat
TBD - max
- Type: SystemInt64
TBD
Type Parameters
- TIn
- TBD
- TOut
- TBD
- TMat
- TBD
Return Value
Type: FlowTIn, TOut, TMatTBD
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type FlowTIn, TOut, TMat. When you use instance method syntax to call this method, omit the first parameter. For more information, see Extension Methods (Visual Basic) or Extension Methods (C# Programming Guide).See Also