| SourceOperationsLimitT, 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 backpressures
Completes when the defined number of elements has been taken or upstream completes
Cancels when the defined number of elements has been taken or downstream cancels
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax public static Source<T, TMat> Limit<T, TMat>(
this Source<T, TMat> flow,
long max
)
[<ExtensionAttribute>]
static member Limit :
flow : Source<'T, 'TMat> *
max : int64 -> Source<'T, 'TMat>
Parameters
- flow
- Type: Akka.Streams.DslSourceT, TMat
TBD - max
- Type: SystemInt64
TBD
Type Parameters
- T
- TBD
- TMat
- TBD
Return Value
Type:
SourceT,
TMatTBD
Usage Note
In Visual Basic and C#, you can call this method as an instance method on any object of type
SourceT,
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