Package akka.stream.impl

Class ProcessorModule<In,Out,Mat>

java.lang.Object

akka.stream.impl.ProcessorModule<In,Out,Mat>

All Implemented Interfaces:

Graph<FlowShape<In,Out>,Mat>, StreamLayout.AtomicModule<FlowShape<In,Out>,Mat>, java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

public final class ProcessorModule<In,Out,Mat>
extends java.lang.Object
implements StreamLayout.AtomicModule<FlowShape<In,Out>,Mat>, scala.Product, scala.Serializable

INTERNAL API

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ProcessorModule(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor, Attributes attributes)

Method Summary

Modifier and Type	Method	Description
static <In,Out,Mat> Attributes	$lessinit$greater$default$2()
static <In,Out,Mat> ProcessorModule<In,Out,Mat>	apply(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor, Attributes attributes)
static <In,Out,Mat> Attributes	apply$default$2()
Attributes	attributes()
boolean	canEqual(java.lang.Object x$1)
<In,Out,Mat> ProcessorModule<In,Out,Mat>	copy(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor, Attributes attributes)
<In,Out,Mat> scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>>	copy$default$1()
<In,Out,Mat> Attributes	copy$default$2()
scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>>	createProcessor()
boolean	equals(java.lang.Object x$1)
int	hashCode()
Inlet<In>	inPort()
Outlet<Out>	outPort()
int	productArity()
java.lang.Object	productElement(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
FlowShape<In,Out>	shape()	The shape of a graph is all that is externally visible: its inlets and outlets.
java.lang.String	toString()
LinearTraversalBuilder	traversalBuilder()	INTERNAL API.
static <In,Out,Mat> scala.Option<scala.Tuple2<scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>>,Attributes>>	unapply(ProcessorModule<In,Out,Mat> x$0)
ProcessorModule<In,Out,Mat>	withAttributes(Attributes attributes)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

ProcessorModule

public ProcessorModule(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor,
                       Attributes attributes)

Method Detail

$lessinit$greater$default$2

public static <In,Out,Mat> Attributes $lessinit$greater$default$2()

apply

public static <In,Out,Mat> ProcessorModule<In,Out,Mat> apply(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor,
                                                                                     Attributes attributes)

apply$default$2

public static <In,Out,Mat> Attributes apply$default$2()

unapply

public static <In,Out,Mat> scala.Option<scala.Tuple2<scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>>,Attributes>> unapply(ProcessorModule<In,Out,Mat> x$0)

createProcessor

public scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor()

attributes

public Attributes attributes()

inPort

public Inlet<In> inPort()

outPort

public Outlet<Out> outPort()

shape

public FlowShape<In,Out> shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

Specified by:

shape in interface Graph<In,Out>

Returns:

(undocumented)

withAttributes

public ProcessorModule<In,Out,Mat> withAttributes(Attributes attributes)

Specified by:

withAttributes in interface Graph<In,Out>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

traversalBuilder

public LinearTraversalBuilder traversalBuilder()

Description copied from interface: Graph

INTERNAL API.

Every materializable element must be backed by a stream layout module

Specified by:

traversalBuilder in interface Graph<In,Out>

Returns:

(undocumented)

copy

public <In,Out,Mat> ProcessorModule<In,Out,Mat> copy(scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> createProcessor,
                                                                             Attributes attributes)

copy$default$1

public <In,Out,Mat> scala.Function0<scala.Tuple2<org.reactivestreams.Processor<In,Out>,Mat>> copy$default$1()

copy$default$2

public <In,Out,Mat> Attributes copy$default$2()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object