akka

stream

package stream

Content Hierarchy Learn more about scaladoc diagrams
UniformFanOutShape[I, O]UniformFanInShape[T, O]StreamTcpExceptionConnectionExceptionBindFailedExceptionSourceShape[T]SinkShape[T]ShapeFlowShape[I, O]FanOutShape[I]FanInShape[O]ClosedShapeBidiShape[In1, Out1, In2, Out2]AmorphousShapeAbstractShapeOutPortOutlet[T]MaterializerActorMaterializerInPortInlet[T]FanOutShape9[I, O0, O1, O2, O3, O4, O5, O6, O7, O8]FanOutShape8[I, O0, O1, O2, O3, O4, O5, O6, O7]FanOutShape7[I, O0, O1, O2, O3, O4, O5, O6]FanOutShape6[I, O0, O1, O2, O3, O4, O5]FanOutShape5[I, O0, O1, O2, O3, O4]FanOutShape4[I, O0, O1, O2, O3]FanOutShape3[I, O0, O1, O2]FanOutShape22[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18, O19, O20, O21]FanOutShape21[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18, O19, O20]FanOutShape20[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18, O19]FanOutShape2[I, O0, O1]FanOutShape19[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18]FanOutShape18[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17]FanOutShape17[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16]FanOutShape16[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15]FanOutShape15[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14]FanOutShape14[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13]FanOutShape13[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12]FanOutShape12[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11]FanOutShape11[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10]FanOutShape10[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9]FanInShape9[T0, T1, T2, T3, T4, T5, T6, T7, T8, O]FanInShape8[T0, T1, T2, T3, T4, T5, T6, T7, O]FanInShape7[T0, T1, T2, T3, T4, T5, T6, O]FanInShape6[T0, T1, T2, T3, T4, T5, O]FanInShape5[T0, T1, T2, T3, T4, O]FanInShape4[T0, T1, T2, T3, O]FanInShape3[T0, T1, T2, O]FanInShape22[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, O]FanInShape21[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, O]FanInShape20[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, O]FanInShape2[T0, T1, O]FanInShape1N[T0, T1, O]FanInShape19[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, O]FanInShape18[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, O]FanInShape17[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, O]FanInShape16[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, O]FanInShape15[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, O]FanInShape14[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, O]FanInShape13[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, O]FanInShape12[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, O]FanInShape11[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, O]FanInShape10[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, O]ClosedShapeBindFailedException
Visibility
  1. Public
  2. All

Type Members

  1. final case class AbruptTerminationException(actor: ActorRef) extends RuntimeException with NoStackTrace with Product with Serializable

    This exception signals that an actor implementing a Reactive Streams Subscriber, Publisher or Processor has been terminated without being notified by an onError, onComplete or cancel signal.

  2. abstract class AbstractShape extends Shape

    Java API for creating custom Shape types.

  3. abstract class ActorMaterializer extends Materializer

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

  4. final class ActorMaterializerSettings extends AnyRef

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

  5. case class AmorphousShape(inlets: Seq[Inlet[_]], outlets: Seq[Outlet[_]]) extends Shape with Product with Serializable

    This type of Shape can express any number of inputs and outputs at the expense of forgetting about their specific types.

  6. final case class Attributes extends Product with Serializable

    Holds attributes which can be used to alter akka.stream.scaladsl.Flow / akka.stream.javadsl.Flow or akka.stream.scaladsl.FlowGraph / akka.stream.javadsl.FlowGraph materialization.

  7. final case class BidiShape[-In1, +Out1, -In2, +Out2](in1: Inlet[In1], out1: Outlet[Out1], in2: Inlet[In2], out2: Outlet[Out2]) extends Shape with Product with Serializable

    A bidirectional flow of elements that consequently has two inputs and two outputs, arranged like this:

  8. abstract class BindFailedException extends StreamTcpException

  9. sealed abstract class ClosedShape extends Shape

    This Shape is used for graphs that have neither open inputs nor open outputs.

  10. class ConnectionException extends StreamTcpException

  11. abstract class FanInShape[O] extends Shape

  12. class FanInShape10[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, O] extends FanInShape[O]

  13. class FanInShape11[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, O] extends FanInShape[O]

  14. class FanInShape12[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, O] extends FanInShape[O]

  15. class FanInShape13[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, O] extends FanInShape[O]

  16. class FanInShape14[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, O] extends FanInShape[O]

  17. class FanInShape15[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, O] extends FanInShape[O]

  18. class FanInShape16[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, O] extends FanInShape[O]

  19. class FanInShape17[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, O] extends FanInShape[O]

  20. class FanInShape18[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, O] extends FanInShape[O]

  21. class FanInShape19[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, O] extends FanInShape[O]

  22. class FanInShape1N[T0, T1, O] extends FanInShape[O]

  23. class FanInShape2[T0, T1, O] extends FanInShape[O]

  24. class FanInShape20[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, O] extends FanInShape[O]

  25. class FanInShape21[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, O] extends FanInShape[O]

  26. class FanInShape22[T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19, T20, T21, O] extends FanInShape[O]

  27. class FanInShape3[T0, T1, T2, O] extends FanInShape[O]

  28. class FanInShape4[T0, T1, T2, T3, O] extends FanInShape[O]

  29. class FanInShape5[T0, T1, T2, T3, T4, O] extends FanInShape[O]

  30. class FanInShape6[T0, T1, T2, T3, T4, T5, O] extends FanInShape[O]

  31. class FanInShape7[T0, T1, T2, T3, T4, T5, T6, O] extends FanInShape[O]

  32. class FanInShape8[T0, T1, T2, T3, T4, T5, T6, T7, O] extends FanInShape[O]

  33. class FanInShape9[T0, T1, T2, T3, T4, T5, T6, T7, T8, O] extends FanInShape[O]

  34. abstract class FanOutShape[I] extends Shape

  35. class FanOutShape10[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9] extends FanOutShape[I]

  36. class FanOutShape11[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10] extends FanOutShape[I]

  37. class FanOutShape12[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11] extends FanOutShape[I]

  38. class FanOutShape13[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12] extends FanOutShape[I]

  39. class FanOutShape14[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13] extends FanOutShape[I]

  40. class FanOutShape15[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14] extends FanOutShape[I]

  41. class FanOutShape16[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15] extends FanOutShape[I]

  42. class FanOutShape17[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16] extends FanOutShape[I]

  43. class FanOutShape18[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17] extends FanOutShape[I]

  44. class FanOutShape19[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18] extends FanOutShape[I]

  45. class FanOutShape2[I, O0, O1] extends FanOutShape[I]

  46. class FanOutShape20[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18, O19] extends FanOutShape[I]

  47. class FanOutShape21[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18, O19, O20] extends FanOutShape[I]

  48. class FanOutShape22[I, O0, O1, O2, O3, O4, O5, O6, O7, O8, O9, O10, O11, O12, O13, O14, O15, O16, O17, O18, O19, O20, O21] extends FanOutShape[I]

  49. class FanOutShape3[I, O0, O1, O2] extends FanOutShape[I]

  50. class FanOutShape4[I, O0, O1, O2, O3] extends FanOutShape[I]

  51. class FanOutShape5[I, O0, O1, O2, O3, O4] extends FanOutShape[I]

  52. class FanOutShape6[I, O0, O1, O2, O3, O4, O5] extends FanOutShape[I]

  53. class FanOutShape7[I, O0, O1, O2, O3, O4, O5, O6] extends FanOutShape[I]

  54. class FanOutShape8[I, O0, O1, O2, O3, O4, O5, O6, O7] extends FanOutShape[I]

  55. class FanOutShape9[I, O0, O1, O2, O3, O4, O5, O6, O7, O8] extends FanOutShape[I]

  56. final case class FlowShape[-I, +O](inlet: Inlet[I], outlet: Outlet[O]) extends Shape with Product with Serializable

    A Flow Shape has exactly one input and one output, it looks from the outside like a pipe (but it can be a complex topology of streams within of course).

  57. trait Graph[+S <: Shape, +M] extends AnyRef

  58. sealed abstract class InPort extends AnyRef

    An input port of a StreamLayout.

  59. final class Inlet[-T] extends InPort

  60. class MaterializationException extends RuntimeException

    This exception or subtypes thereof should be used to signal materialization failures.

  61. abstract class Materializer extends AnyRef

  62. final case class Optimizations(collapsing: Boolean, elision: Boolean, simplification: Boolean, fusion: Boolean) extends Product with Serializable

  63. sealed abstract class OutPort extends AnyRef

    An output port of a StreamLayout.

  64. final class Outlet[+T] extends OutPort

  65. 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.

  66. abstract class Shape extends AnyRef

    A Shape describes the inlets and outlets of a Graph.

  67. final case class SinkShape[-T](inlet: Inlet[T]) extends Shape with Product with Serializable

    A Sink Shape has exactly one input and no outputs, it models a data sink.

  68. final case class SourceShape[+T](outlet: Outlet[T]) extends Shape with Product with Serializable

    A Source Shape has exactly one output and no inputs, it models a source of data.

  69. final class StreamSubscriptionTimeoutSettings extends AnyRef

  70. sealed abstract class StreamSubscriptionTimeoutTerminationMode extends AnyRef

  71. class StreamTcpException extends RuntimeException with NoStackTrace

  72. class UniformFanInShape[-T, O] extends FanInShape[O]

  73. class UniformFanOutShape[I, O] extends FanOutShape[I]

Value Members

  1. object ActorAttributes

    Attributes for the ActorMaterializer.

  2. object ActorMaterializer

  3. object ActorMaterializerSettings

  4. object Attributes extends Serializable

    Note that more attributes for the ActorMaterializer are defined in ActorAttributes.

  5. object BidiShape extends Serializable

  6. object BindFailedException extends BindFailedException with Product with Serializable

  7. object ClosedShape extends ClosedShape

  8. object FanInShape

  9. object FanOutShape

  10. object Inlet

    An Inlet is a typed input to a Shape.

  11. object Optimizations extends Serializable

  12. object Outlet

    An Outlet is a typed output to a Shape.

  13. object OverflowStrategy

  14. object StreamSubscriptionTimeoutSettings

  15. object StreamSubscriptionTimeoutTerminationMode

  16. object Supervision

  17. object UniformFanInShape

  18. object UniformFanOutShape

  19. package actor

  20. package extra

  21. package impl

  22. package io

  23. package javadsl

  24. package scaladsl

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

  25. package stage

  26. package testkit

Ungrouped