object Sink

akka.stream.scaladsl.Sink factories operating with java.util.concurrent.Flow.* interfaces.

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

Value Members

  1. final def asPublisher[T](fanout: Boolean): Sink[T, Publisher[T]]

    A Sink that materializes into a java.util.concurrent.Flow.Publisher.

    A Sink that materializes into a java.util.concurrent.Flow.Publisher.

    If fanout is WITH_FANOUT, the materialized Publisher will support multiple Subscribers and the size of the inputBuffer configured for this operator becomes the maximum number of elements that the fastest java.util.concurrent.Flow.Subscriber can be ahead of the slowest one before slowing the processing down due to back pressure.

    If fanout is WITHOUT_FANOUT then the materialized Publisher will only support a single Subscriber and reject any additional Subscribers.

  2. final def fromSubscriber[T](s: Subscriber[T]): Sink[T, NotUsed]

    Helper to create from java.util.concurrent.Flow.Subscriber.