akka.stream

scaladsl

package scaladsl

Visibility
  1. Public
  2. All

Type Members

  1. trait Duct[In, +Out] extends AnyRef

    A Duct provides the same kind of formulation of stream transformations as a Flow.

    A Duct provides the same kind of formulation of stream transformations as a Flow. The difference is that it is not attached to an input source.

    The pipeline must be materialized by calling the #produceTo, #consume or #build methods on it and then attach the Consumer representing the input side of the Duct to an upstream Producer.

  2. trait Flow[+T] extends AnyRef

    Scala API: The Flow DSL allows the formulation of stream transformations based on some input.

    Scala API: The Flow DSL allows the formulation of stream transformations based on some input. The starting point can be a collection, an iterator, a block of code which is evaluated repeatedly or a org.reactivestreams.api.Producer.

    See Reactive Streams for details.

    Each DSL element produces a new Flow that can be further transformed, building up a description of the complete transformation pipeline. In order to execute this pipeline the Flow must be materialized by calling the #toFuture, #consume, #onComplete, or #toProducer methods on it.

    It should be noted that the streams modeled by this library are “hot”, meaning that they asynchronously flow through a series of processors without detailed control by the user. In particular it is not predictable how many elements a given transformation step might buffer before handing elements downstream, which means that transformation functions may be invoked more often than for corresponding transformations on strict collections like List. *An important consequence* is that elements that were produced into a stream may be discarded by later processors, e.g. when using the #take combinator.

    By default every operation is executed within its own akka.actor.Actor to enable full pipelining of the chained set of computations. This behavior is determined by the akka.stream.FlowMaterializer which is required by those methods that materialize the Flow into a series of org.reactivestreams.api.Processor instances. The returned reactive stream is fully started and active.

Value Members

  1. object Duct

  2. object Flow

    Scala API

Ungrouped