Packages

object DrainingControl

Source
Consumer.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DrainingControl
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply[T]: (Control, Future[T]) => DrainingControl[T]

    Combine the consumer control and a stream completion signal materialized values into one, so that the stream can be stopped in a controlled way without losing commits.

    Combine the consumer control and a stream completion signal materialized values into one, so that the stream can be stopped in a controlled way without losing commits.

    For use in the toMat combination of materialized values.

  2. def apply[T](tuple: (Control, Future[T])): DrainingControl[T]

    Combine the consumer control and a stream completion signal materialized values into one, so that the stream can be stopped in a controlled way without losing commits.

    Combine the consumer control and a stream completion signal materialized values into one, so that the stream can be stopped in a controlled way without losing commits.

    For use in mapMaterializedValue.