GraphStageLogic.SubSinkInlet

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 operator shuts down lest the corresponding Sink be left hanging.

Constructor Summary

Constructors
Constructor Description

SubSinkInlet(java.lang.String name)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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

cancel
```
public void cancel()
```

grab
```
public T grab()
```

hasBeenPulled
```
public boolean hasBeenPulled()
```

isAvailable
```
public boolean isAvailable()
```

isClosed
```
public boolean isClosed()
```

pull
```
public void pull()
```

setHandler

public void setHandler(InHandler handler)

sink

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

toString
```
public java.lang.String toString()
```
Overrides:

toString in class java.lang.Object