JavaFlowSupport.Flow$

java.lang.Object

org.apache.pekko.stream.scaladsl.JavaFlowSupport.Flow$

Enclosing class:: JavaFlowSupport

public static class JavaFlowSupport.Flow$ extends Object

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

Field Summary

Fields

Modifier and Type

Field

Description

static final JavaFlowSupport.Flow$

MODULE$

Static reference to the singleton instance of this Scala object.
Constructor Summary

Constructors

Constructor

Description

Flow$()
Method Summary

Modifier and Type

Method

Description

<I, O> Flow<I,O,NotUsed>

fromProcessor(scala.Function0<Flow.Processor<I,O>> processorFactory)

Creates a Flow from a Reactive Streams Processor

<I, O, M> Flow<I,O,M>

fromProcessorMat(scala.Function0<scala.Tuple2<Flow.Processor<I,O>,M>> processorFactory)

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

<In, Out, Mat> RunnableGraph<Flow.Processor<In,Out>>

toProcessor(Flow<In,Out,Mat> self)

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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- MODULE$
  
  public static final JavaFlowSupport.Flow$ MODULE$
  
  Static reference to the singleton instance of this Scala object.
Constructor Details
- Flow$
  
  public Flow$()
Method Details
- fromProcessor
  
  public <I, O> Flow<I,O,NotUsed> fromProcessor(scala.Function0<Flow.Processor<I,O>> processorFactory)
  
  Creates a Flow from a Reactive Streams Processor
- fromProcessorMat
  
  public <I, O, M> Flow<I,O,M> fromProcessorMat(scala.Function0<scala.Tuple2<Flow.Processor<I,O>,M>> processorFactory)
  
  Creates a Flow from a Reactive Streams Flow.Processor and returns a materialized value.
- toProcessor
  
  public <In, Out, Mat> RunnableGraph<Flow.Processor<In,Out>> toProcessor(Flow<In,Out,Mat> self)
  
  Converts this Flow to a RunnableGraph that materializes to a Reactive Streams Flow.Processor 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.