| GraphStageLogicReadManyT Method |
Read a number of elements from the given inlet and continue with the given function,
suspending execution if necessary. This action replaces the
InHandler
for the given inlet if suspension is needed and reinstalls the current
handler upon receiving the last
OnPush signal.
If upstream closes before N elements have been read,
the
onComplete function is invoked with the elements which were read.
Namespace:
Akka.Streams.Stage
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax protected void ReadMany<T>(
Inlet<T> inlet,
int n,
Action<IEnumerable<T>> andThen,
Action<IEnumerable<T>> onComplete
)
member ReadMany :
inlet : Inlet<'T> *
n : int *
andThen : Action<IEnumerable<'T>> *
onComplete : Action<IEnumerable<'T>> -> unit
Parameters
- inlet
- Type: Akka.StreamsInletT
TBD - n
- Type: SystemInt32
TBD - andThen
- Type: SystemActionIEnumerableT
TBD - onComplete
- Type: SystemActionIEnumerableT
TBD
Type Parameters
- T
- TBD
Exceptions Exception | Condition |
---|
ArgumentException |
This exception is thrown when the specified n is less than zero.
|
IllegalStateException |
This exception is thrown when the specified inlet is currently reading.
|
See Also