 | GraphStageLogicSubSourceOutletT Class |
INTERNAL API
This allows the dynamic creation of an Outlet for a GraphStage which is
connected to a Source that is available for materialization (e.g. using
the SubFusingMaterializer). Care needs to be taken to complete this
Outlet when the stage shuts down lest the corresponding Sink be left
hanging. It is good practice to use the Timeout(TimeSpan) method to cancel this
Outlet in case the corresponding Source is not materialized within a
given time limit, see e.g. ActorMaterializerSettings.
Inheritance HierarchyNamespace: Akka.Streams.Stage
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
SyntaxThe GraphStageLogicSubSourceOutletT type exposes the following members.
Constructors| Name | Description | |
|---|---|---|
 | GraphStageLogicSubSourceOutletT |
TBD
|
Properties| Name | Description | |
|---|---|---|
 | IsAvailable |
Returns true if this output port can be pushed.
|
| IsClosed |
Returns true if this output port is closed, but caution
THIS WORKS DIFFERENTLY THAN THE NORMAL isClosed(out).
Due to possibly asynchronous shutdown it may not return
true immediately after Complete or Fail(Exception) have returned.
|
| Source |
Get the Source for this dynamic output port.
|
Methods| Name | Description | |
|---|---|---|
| Complete |
Complete this output port.
|
| Equals | Determines whether the specified object is equal to the current object. (Inherited from Object.) |
| Fail |
Fail this output port.
|
 | Finalize | Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.) |
| GetHashCode | Serves as the default hash function. (Inherited from Object.) |
| GetType | Gets the Type of the current instance. (Inherited from Object.) |
| MemberwiseClone | Creates a shallow copy of the current Object. (Inherited from Object.) |
| Push |
Push to this output port.
|
| SetHandler |
Set OutHandler for this dynamic output port; this needs to be done before
the first substream callback can arrive.
|
| Timeout |
Set the source into timed-out mode if it has not yet been materialized.
|
| ToString | Returns a string that represents the current object. (Overrides ObjectToString.) |
Extension Methods| Name | Description | |
|---|---|---|
 | AsInstanceOfT |
TBD
(Defined by Extensions.) |
| Match | Overloaded.
Matches the specified target.
(Defined by PatternMatch.) |
| MatchT | Overloaded.
Matches the specified target and return a result of target processing.
(Defined by PatternMatch.) |
See Also