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). Completion, cancellation and failure of the parent operator is automatically delegated to instances of SubSinkInlet to avoid resource leaks.
To be thread safe this method must only be called from either the constructor of the graph operator during materialization or one of the methods invoked by the graph operator machinery, such as onPush and onPull.

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()`
`void`	`cancel(java.lang.Throwable cause)`
`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()
```

cancel

public void cancel(java.lang.Throwable cause)

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