Package org.apache.pekko.http.impl.util

Class One2OneBidiFlow$

java.lang.Object
org.apache.pekko.http.impl.util.One2OneBidiFlow$
public class One2OneBidiFlow$ extends Object
INTERNAL API

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    One2OneBidiFlow$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    <I, O> org.apache.pekko.stream.scaladsl.BidiFlow<I,I,O,O,org.apache.pekko.NotUsed>
    apply(int maxPending, scala.Function1<Object,Throwable> outputTruncationException, scala.Function1<Object,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 Details

    • MODULE$

      public static final One2OneBidiFlow$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • One2OneBidiFlow$

      public One2OneBidiFlow$()

  • Method Details

    • apply

      public <I, O> org.apache.pekko.stream.scaladsl.BidiFlow<I,I,O,O,org.apache.pekko.NotUsed> apply(int maxPending, scala.Function1<Object,Throwable> outputTruncationException, scala.Function1<Object,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)