class SubSinkInlet[T] extends AnyRef

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.

Source
GraphStage.scala
Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SubSinkInlet
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SubSinkInlet(name: String)

Value Members

  1. def cancel(cause: Throwable): Unit
  2. def cancel(): Unit
  3. def grab(): T
  4. def hasBeenPulled: Boolean
  5. def isAvailable: Boolean
  6. def isClosed: Boolean
  7. def pull(): Unit
  8. def setHandler(handler: InHandler): Unit
  9. def sink: [SinkShape[T], NotUsed]
  10. def toString(): String
    Definition Classes
    SubSinkInlet → AnyRef → Any