object Source

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

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

Value Members

  1. final def asSubscriber[T]: Source[T, Subscriber[T]]

    Creates a Source that is materialized as a java.util.concurrent.Flow.Subscriber

    Creates a Source that is materialized as a java.util.concurrent.Flow.Subscriber

    See also

    See also Source.asSubscriber if wanting to integrate with org.reactivestreams.Subscriber instead (which carries the same semantics, however existed before RS's inclusion in Java 9).

  2. final def fromPublisher[T](publisher: Publisher[T]): Source[T, NotUsed]

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

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

    Construct a transformation starting with given publisher. The transformation steps are executed by a series of java.util.concurrent.Flow.Processor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.

    See also

    See also Source.fromPublisher if wanting to integrate with org.reactivestreams.Publisher instead (which carries the same semantics, however existed before RS's inclusion in Java 9).