o

play.api.libs.streams

PekkoStreams

object PekkoStreams

Utilities for Pekko Streams merging and bypassing of packets.

Source
PekkoStreams.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PekkoStreams
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def bypassWith[In, FlowIn, Out](splitter: Flow[In, Either[FlowIn, Out], _], mergeStrategy: Graph[UniformFanInShape[Out, Out], _] = onlyFirstCanFinishMerge[Out](2)): (Flow[FlowIn, Out, _]) => Flow[In, Out, _]

    Using the given splitter flow, allow messages to bypass a flow.

    Using the given splitter flow, allow messages to bypass a flow.

    If the splitter flow produces Left, they will be fed into the flow. If it produces Right, they will bypass the flow.

  2. def bypassWith[In, FlowIn, Out](splitter: (In) => Either[FlowIn, Out]): (Flow[FlowIn, Out, _]) => Flow[In, Out, _]

    Bypass the given flow using the given splitter function.

    Bypass the given flow using the given splitter function.

    If the splitter function returns Left, they will go through the flow. If it returns Right, they will bypass the flow.

  3. def ignoreAfterCancellation[T]: Flow[T, T, Future[Done]]

    A flow that will ignore downstream cancellation, and instead will continue receiving and ignoring the stream.

  4. def ignoreAfterFinish[T]: Flow[T, T, _]

    A flow that will ignore upstream finishes.

  5. def onlyFirstCanFinishMerge[T](inputPorts: Int): Graph[UniformFanInShape[T, T], NotUsed]