akka

stream

package stream

Content Hierarchy Learn more about scaladoc diagrams
Visibility
  1. Public
  2. All

Type Members

  1. abstract class FlattenStrategy[-T, U] extends AnyRef

    Strategy that defines how a stream of streams should be flattened into a stream of simple elements.

  2. abstract class FlowMaterializer extends AnyRef

    A FlowMaterializer takes the list of transformations comprising a akka.stream.scaladsl.Flow and materializes them in the form of org.reactivestreams.api.Processor instances.

    A FlowMaterializer takes the list of transformations comprising a akka.stream.scaladsl.Flow and materializes them in the form of org.reactivestreams.api.Processor instances. How transformation steps are split up into asynchronous regions is implementation dependent.

  3. case class MaterializerSettings(initialFanOutBufferSize: Int = 4, maxFanOutBufferSize: Int = 16, initialInputBufferSize: Int = 4, maximumInputBufferSize: Int = 16, upstreamSubscriptionTimeout: FiniteDuration = 3.seconds, downstreamSubscriptionTimeout: FiniteDuration = 3.seconds, dispatcher: String = Deploy.NoDispatcherGiven) extends Product with Serializable

    The buffers employed by the generated Processors can be configured by creating an appropriate instance of this class.

    The buffers employed by the generated Processors can be configured by creating an appropriate instance of this class.

    This will likely be replaced in the future by auto-tuning these values at runtime.

  4. sealed abstract class OverflowStrategy extends AnyRef

    Represents a strategy that decides how to deal with a buffer that is full but is about to receive a new element.

  5. abstract class TimerTransformer[-T, +U] extends Transformer[T, U]

    Transformer with support for scheduling keyed (named) timer events.

  6. abstract class Transformer[-T, +U] extends AnyRef

    General interface for stream transformation.

    General interface for stream transformation.

    It is possible to keep state in the concrete Transformer instance with ordinary instance variables. The Transformer is executed by an actor and therefore you don not have to add any additional thread safety or memory visibility constructs to access the state from the callback methods.

    See also

    akka.stream.javadsl.Flow#transform

    akka.stream.scaladsl.Flow#transform

Value Members

  1. object FlattenStrategy

  2. object FlowMaterializer

  3. object MaterializerSettings extends Serializable

  4. object OverflowStrategy

  5. object Stop extends RuntimeException with NoStackTrace with Product with Serializable

    This exception must be thrown from a callback-based stream producer to signal the end of stream (if the produced stream is not infinite).

    This exception must be thrown from a callback-based stream producer to signal the end of stream (if the produced stream is not infinite). This is used for example in akka.stream.scaladsl.Flow#apply (the variant which takes a closure).

  6. package actor

  7. package extra

  8. package impl

  9. package io

  10. package javadsl

  11. package scaladsl

Ungrouped