Package akka.stream.stage
Class GraphStageLogic.SubSourceOutlet<T>
- java.lang.Object
-
- akka.stream.stage.GraphStageLogic.SubSourceOutlet<T>
-
- Enclosing class:
- GraphStageLogic
public class GraphStageLogic.SubSourceOutlet<T> extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description SubSourceOutlet(java.lang.String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
complete()
Complete this output port.void
fail(java.lang.Throwable ex)
Fail this output port.boolean
isAvailable()
Returnstrue
if this output port can be pushed.boolean
isClosed()
Returnstrue
if this output port is closed, but caution THIS WORKS DIFFERENTLY THAN THE NORMAL isClosed(out).void
push(T elem)
Push to this output port.void
setHandler(OutHandler handler)
Set OutHandler for this dynamic output port; this needs to be done before the first substream callback can arrive.Graph<SourceShape<T>,NotUsed>
source()
Get the Source for this dynamic output port.void
timeout(scala.concurrent.duration.FiniteDuration d)
Set the source into timed-out mode if it has not yet been materialized.java.lang.String
toString()
-
-
-
Method Detail
-
complete
public void complete()
Complete this output port.
-
fail
public void fail(java.lang.Throwable ex)
Fail this output port.- Parameters:
ex
- (undocumented)
-
isAvailable
public boolean isAvailable()
Returnstrue
if this output port can be pushed.- Returns:
- (undocumented)
-
isClosed
public boolean isClosed()
Returnstrue
if this output port is closed, but caution THIS WORKS DIFFERENTLY THAN THE NORMAL isClosed(out). Due to possibly asynchronous shutdown it may not returntrue
immediately aftercomplete()
orfail()
have returned.- Returns:
- (undocumented)
-
push
public void push(T elem)
Push to this output port.- Parameters:
elem
- (undocumented)
-
setHandler
public void setHandler(OutHandler handler)
Set OutHandler for this dynamic output port; this needs to be done before the first substream callback can arrive.- Parameters:
handler
- (undocumented)
-
source
public Graph<SourceShape<T>,NotUsed> source()
Get the Source for this dynamic output port.- Returns:
- (undocumented)
-
timeout
public void timeout(scala.concurrent.duration.FiniteDuration d)
Set the source into timed-out mode if it has not yet been materialized.- Parameters:
d
- (undocumented)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-