akka.stream.stage

Class GraphStageLogic.SubSinkInlet<T>

java.lang.Object

akka.stream.stage.GraphStageLogic.SubSinkInlet<T>

Enclosing class:

GraphStageLogic

public class GraphStageLogic.SubSinkInlet<T>
extends java.lang.Object

INTERNAL API

This allows the dynamic creation of an Inlet for a GraphStage which is connected to a Sink that is available for materialization (e.g. using the subFusingMaterializer). Care needs to be taken to cancel this Inlet when the stage shuts down lest the corresponding Sink be left hanging.

Constructor Summary

Constructors

Constructor and Description
SubSinkInlet(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	cancel()
T	grab()
boolean	hasBeenPulled()
boolean	isAvailable()
boolean	isClosed()
void	pull()
void	setHandler(InHandler handler)
Graph<SinkShape<T>,NotUsed>	sink()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SubSinkInlet

public SubSinkInlet(java.lang.String name)

Method Detail

sink

public Graph<SinkShape<T>,NotUsed> sink()

setHandler

public void setHandler(InHandler handler)

isAvailable

public boolean isAvailable()

isClosed

public boolean isClosed()

hasBeenPulled

public boolean hasBeenPulled()

grab

public T grab()

pull

public void pull()

cancel

public void cancel()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object