org.apache.pekko.http.impl.util

Class One2OneBidiFlow$

java.lang.Object

org.apache.pekko.http.impl.util.One2OneBidiFlow$

public class One2OneBidiFlow$
extends java.lang.Object

INTERNAL API

Field Summary

Fields

Modifier and Type	Field and Description
static One2OneBidiFlow$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
One2OneBidiFlow$()

Method Summary

Modifier and Type	Method and Description
<I,O> org.apache.pekko.stream.scaladsl.BidiFlow<I,I,O,O,org.apache.pekko.NotUsed>	apply(int maxPending, scala.Function1<java.lang.Object,java.lang.Throwable> outputTruncationException, scala.Function1<java.lang.Object,java.lang.Throwable> unexpectedOutputException) Creates a generic BidiFlow which verifies that another flow produces exactly one output element per input element, at the right time.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final One2OneBidiFlow$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

One2OneBidiFlow$

public One2OneBidiFlow$()

Method Detail

apply

public <I,O> org.apache.pekko.stream.scaladsl.BidiFlow<I,I,O,O,org.apache.pekko.NotUsed> apply(int maxPending,
                                                                                               scala.Function1<java.lang.Object,java.lang.Throwable> outputTruncationException,
                                                                                               scala.Function1<java.lang.Object,java.lang.Throwable> unexpectedOutputException)

Creates a generic BidiFlow which verifies that another flow produces exactly one output element per input element, at the right time. Specifically it

1. triggers an UnexpectedOutputException if the inner flow produces an output element before having consumed the respective input element. 2. triggers an OutputTruncationException if the inner flow completes before having produced an output element for every input element. 3. triggers an OutputTruncationException if the inner flow cancels its inputs before the upstream completes its stream of inputs. 4. Backpressures the input side if the maximum number of pending output elements has been reached, which is given via the maxPending parameter. You can use -1 to disable this feature.

Parameters:

maxPending - (undocumented)

outputTruncationException - (undocumented)

unexpectedOutputException - (undocumented)

Returns:

(undocumented)