object Flow

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

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

Value Members

  1. def fromProcessor[I, O](processorFactory: () => Processor[I, O]): Flow[I, O, NotUsed]

    Creates a Flow from a Reactive Streams org.reactivestreams.Processor

  2. def fromProcessorMat[I, O, M](processorFactory: () => (Processor[I, O], M)): Flow[I, O, M]

    Creates a Flow from a Reactive Streams java.util.concurrent.Flow.Processor and returns a materialized value.

  3. def toProcessor[In, Out, Mat](self: Flow[In, Out, Mat]): RunnableGraph[Processor[In, Out]]

    Converts this Flow to a that materializes to a Reactive Streams java.util.concurrent.Flow.Processor which implements the operations encapsulated by this Flow.

    Converts this Flow to a that materializes to a Reactive Streams which implements the operations encapsulated by this Flow. Every materialization results in a new Processor instance, i.e. the returned RunnableGraph is reusable.

    returns

    A RunnableGraph that materializes to a Processor when run() is called on it.