Control

The materialized value of the consumer sources. Used for control shutdown.

Not for user extension.

Linear Supertypes

Known Subclasses

Ordering

Inherited

Visibility

abstract def drainAndShutdown[T](streamCompletion: CompletionStage[T], executor: Executor): CompletionStage[T]
Stop producing messages and wait for downstream completion or failure before shutting down the source.
Stop producing messages and wait for downstream completion or failure before shutting down the source. This ensures that all consumed events reach the end of the stream.
streamCompletion
typically, the materialized value of a sink (e.g. 'Sink.ignore')
abstract def isShutdown(): CompletionStage[Done]
abstract def shutdown(): CompletionStage[Done]
Shutdown the consumer source.
Shutdown the consumer source. The actor backing the source will stay alive to handle downstream checkpoints.
abstract def stop(): CompletionStage[Done]
Stop emitting events and complete the stream.
Stop emitting events and complete the stream. The actor backing the source will stay alive to handle downstream checkpoints.

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native()
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Packages