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
). Care needs to be taken to cancel this Inlet
when the stage shuts down lest the corresponding Sink be left hanging.
- Source
- GraphStage.scala
- Alphabetic
- By Inheritance
- SubSinkInlet
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new SubSinkInlet(name: String)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to any2stringadd[SubSinkInlet[T]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (SubSinkInlet[T], B)
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to ArrowAssoc[SubSinkInlet[T]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def cancel(): Unit
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
ensuring(cond: (SubSinkInlet[T]) ⇒ Boolean, msg: ⇒ Any): SubSinkInlet[T]
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to Ensuring[SubSinkInlet[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (SubSinkInlet[T]) ⇒ Boolean): SubSinkInlet[T]
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to Ensuring[SubSinkInlet[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): SubSinkInlet[T]
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to Ensuring[SubSinkInlet[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): SubSinkInlet[T]
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to Ensuring[SubSinkInlet[T]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to StringFormat[SubSinkInlet[T]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- def grab(): T
- def hasBeenPulled: Boolean
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- def isAvailable: Boolean
- def isClosed: Boolean
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- def pull(): Unit
- def setHandler(handler: InHandler): Unit
- def sink: Graph[SinkShape[T], NotUsed]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- SubSinkInlet → AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
→[B](y: B): (SubSinkInlet[T], B)
- Implicit
- This member is added by an implicit conversion from SubSinkInlet[T] to ArrowAssoc[SubSinkInlet[T]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc