Package akka.http.impl.util
Class One2OneBidiFlow$
java.lang.Object
akka.http.impl.util.One2OneBidiFlow$
INTERNAL API
-
Field Summary
Modifier and TypeFieldDescriptionstatic final One2OneBidiFlow$
Static reference to the singleton instance of this Scala object. -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescription<I,
O> akka.stream.scaladsl.BidiFlow<I, I, O, O, akka.NotUsed> apply
(int maxPending, scala.Function1<Object, Throwable> outputTruncationException, scala.Function1<Object, Throwable> unexpectedOutputException) Creates a genericBidiFlow
which verifies that another flow produces exactly one output element per input element, at the right time.
-
Field Details
-
MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Constructor Details
-
One2OneBidiFlow$
public One2OneBidiFlow$()
-
-
Method Details
-
apply
public <I,O> akka.stream.scaladsl.BidiFlow<I,I, applyO, O, akka.NotUsed> (int maxPending, scala.Function1<Object, Throwable> outputTruncationException, scala.Function1<Object, Throwable> unexpectedOutputException) Creates a genericBidiFlow
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 anOutputTruncationException
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 themaxPending
parameter. You can use -1 to disable this feature.
- Parameters:
maxPending
- (undocumented)outputTruncationException
- (undocumented)unexpectedOutputException
- (undocumented)- Returns:
- (undocumented)
-