akka.stream

javadsl

package javadsl

Source
package.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. javadsl
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. class BidiFlow[-I1, +O1, -I2, +O2, +Mat] extends Graph[BidiShape[I1, O1, I2, O2], Mat]

  2. trait BidiFlowCreate extends AnyRef

  3. abstract class FlattenStrategy[-S, T] extends scaladsl.FlattenStrategy[S, T]

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

  4. abstract class FlexiMerge[T, Out, S <: Shape] extends Graph[S, Unit]

    Base class for implementing custom merge junctions.

  5. abstract class FlexiRoute[In, S <: Shape] extends Graph[S, Unit]

    Base class for implementing custom route junctions.

  6. class Flow[-In, +Out, +Mat] extends Graph[FlowShape[In, Out], Mat]

    Create a Flow which can process elements of type T.

  7. trait FlowCreate extends AnyRef

  8. trait GraphCreate extends AnyRef

  9. trait RunnableGraph[+Mat] extends Graph[ClosedShape, Mat]

    Java API

  10. class Sink[-In, +Mat] extends Graph[SinkShape[In], Mat]

    Java API

  11. trait SinkCreate extends AnyRef

  12. class Source[+Out, +Mat] extends Graph[SourceShape[Out], Mat]

    Java API

  13. trait SourceCreate extends AnyRef

  14. class Tcp extends Extension

Value Members

  1. object Balance

    Fan-out the stream to several streams.

  2. object BidiFlow

  3. object Broadcast

    Fan-out the stream to several streams.

  4. object Concat

    Takes two streams and outputs an output stream formed from the two input streams by consuming one stream first emitting all of its elements, then consuming the second stream emitting all of its elements.

  5. object FlattenStrategy

  6. object FlexiMerge

  7. object FlexiRoute

  8. object Flow

  9. object FlowGraph

  10. val JavaIdentityFunction: Function[Any, Any]

  11. object Keep

  12. object Merge

    Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

  13. object MergePreferred

    Merge several streams, taking elements as they arrive from input streams (picking from preferred when several have elements ready).

  14. object Sink

    Java API

  15. object Source

    Java API

  16. object Tcp extends ExtensionId[Tcp] with ExtensionIdProvider

  17. object Unzip

    Takes a stream of pair elements and splits each pair to two output streams.

  18. object UnzipWith

    Split one stream into several streams using a splitting function.

  19. object Zip

    Combine the elements of 2 streams into a stream of tuples.

  20. object ZipWith

    Combine the elements of multiple streams into a stream of combined elements using a combiner function.

  21. def combinerToScala[M1, M2, M](f: Function2[M1, M2, M]): (M1, M2) ⇒ M

  22. def javaIdentityFunction[T]: Function[T, T]

Inherited from AnyRef

Inherited from Any

Ungrouped