| GraphStageLogicReadT 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)
Syntax protected 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.StreamsInletT
TBD - andThen
- Type: SystemActionT
TBD - onClose
- Type: SystemAction
TBD
Type Parameters
- T
- TBD
Exceptions Exception | Condition |
---|
IllegalStateException |
This exception is thrown when the specified inlet is currently reading.
|
See Also