org.apache.pekko.http.impl.util

Class One2OneBidiFlow.One2OneBidi<I,O>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,org.apache.pekko.NotUsed>

org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<I,I,O,O>>

org.apache.pekko.http.impl.util.One2OneBidiFlow.One2OneBidi<I,O>

All Implemented Interfaces:

org.apache.pekko.stream.Graph<org.apache.pekko.stream.BidiShape<I,I,O,O>,org.apache.pekko.NotUsed>

Enclosing class:

One2OneBidiFlow

public static class One2OneBidiFlow.One2OneBidi<I,O>
extends org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<I,I,O,O>>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

org.apache.pekko.stream.Graph.GraphMapMatVal<S extends org.apache.pekko.stream.Shape,M>

Constructor Summary

Constructors

Constructor and Description
One2OneBidi(int maxPending, scala.Function1<java.lang.Object,java.lang.Throwable> outputTruncationException, scala.Function1<java.lang.Object,java.lang.Throwable> unexpectedOutputException)

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.stream.stage.GraphStageLogic	createLogic(org.apache.pekko.stream.Attributes effectiveAttributes)
org.apache.pekko.stream.Inlet<O>	fromWrapped()
org.apache.pekko.stream.Inlet<I>	in()
org.apache.pekko.stream.Attributes	initialAttributes()
org.apache.pekko.stream.Outlet<O>	out()
org.apache.pekko.stream.BidiShape<I,I,O,O>	shape()
java.lang.String	toString()
org.apache.pekko.stream.Outlet<I>	toWrapped()

Methods inherited from class org.apache.pekko.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

addAttributes, async, async, async, createLogicAndMaterializedValue, getAttributes, named, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.pekko.stream.Graph

$init$, GraphMapMatVal, mapMaterializedValue

Constructor Detail

One2OneBidi

public One2OneBidi(int maxPending,
                   scala.Function1<java.lang.Object,java.lang.Throwable> outputTruncationException,
                   scala.Function1<java.lang.Object,java.lang.Throwable> unexpectedOutputException)

Method Detail

createLogic

public org.apache.pekko.stream.stage.GraphStageLogic createLogic(org.apache.pekko.stream.Attributes effectiveAttributes)

Specified by:

createLogic in class org.apache.pekko.stream.stage.GraphStage<org.apache.pekko.stream.BidiShape<I,I,O,O>>

fromWrapped

public org.apache.pekko.stream.Inlet<O> fromWrapped()

in

public org.apache.pekko.stream.Inlet<I> in()

initialAttributes

public org.apache.pekko.stream.Attributes initialAttributes()

Overrides:

initialAttributes in class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<org.apache.pekko.stream.BidiShape<I,I,O,O>,org.apache.pekko.NotUsed>

out

public org.apache.pekko.stream.Outlet<O> out()

shape

public org.apache.pekko.stream.BidiShape<I,I,O,O> shape()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

toWrapped

public org.apache.pekko.stream.Outlet<I> toWrapped()