o

akka.stream.contrib

SourceGen

object SourceGen

Source factory methods are placed here

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SourceGen
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. def unfoldFlow[S, E, M](seed: S)(flow: Graph[FlowShape[S, (S, E)], M])(implicit timeout: Timeout): Source[E, M]

    Create a Source that will unfold a value of type S by passing it through a flow.

    Create a Source that will unfold a value of type S by passing it through a flow. The flow should emit a pair of the next state S and output elements of type E. Source completes when the flow completes.

    The timeout parameter specifies waiting time after inner flow provided by the user for unfold flow API cancels upstream, to get also the downstream cancelation (as graceful completion or failure which is propagated). If inner flow fails to complete/fail downstream, stage is failed with an IllegalStateException.

    IMPORTANT CAVEAT: The given flow must not change the number of elements passing through it (i.e. it should output exactly one element for every received element). Ignoring this, will have an unpredicted result, and may result in a deadlock.

  18. def unfoldFlowWith[E, S, O, M](seed: S, flow: Graph[FlowShape[S, O], M])(unfoldWith: (O) ⇒ Option[(S, E)])(implicit timeout: Timeout): Source[E, M]

    Create a Source that will unfold a value of type S by passing it through a flow.

    Create a Source that will unfold a value of type S by passing it through a flow. The flow should emit an output value of type O, that when fed to the unfolding function, generates a pair of the next state S and output elements of type E.

    The timeout parameter specifies waiting time after inner flow provided by the user for unfold flow API cancels upstream, to get also the downstream cancelation (as graceful completion or failure which is propagated). If inner flow fails to complete/fail downstream, stage is failed with an IllegalStateException.

    IMPORTANT CAVEAT: The given flow must not change the number of elements passing through it (i.e. it should output exactly one element for every received element). Ignoring this, will have an unpredicted result, and may result in a deadlock.

  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped