 | GraphStageLogic.Read<T> Method |
Read an element 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
OnPush() signal (before invoking the
andThen function).
Namespace:
Akka.Streams.Stage
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntaxprotected void Read<T>(
Inlet<T> inlet,
Action<T> andThen,
Action onClose
)
member Read :
inlet : Inlet<'T> *
andThen : Action<'T> *
onClose : Action -> unit
Parameters
- inlet
- Type: Akka.Streams.Inlet<T>
TBD - andThen
- Type: System.Action<T>
TBD - onClose
- Type: System.Action
TBD
Type Parameters
- T
- TBD
ExceptionsException | Condition |
---|
IllegalStateException |
This exception is thrown when the specified inlet is currently reading.
|
See Also