p

swave

core

package core

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. final class BufferOverflowFailure extends RuntimeException

    The exception instance thrown by the swave.core.Buffer.OverflowStrategy.Fail when the buffer is full and a new element arrives.

  2. trait Cancellable extends AnyRef
  3. final class ConfigurationException extends RuntimeException
  4. final class Coupling [T] extends AnyRef

    A simple streaming component with one input, one output port and no internal transformation logic.

    A simple streaming component with one input, one output port and no internal transformation logic.

    It is typically used to manually connect two ports of a stream graph that cannot be otherwise connected via the streaming DSL, e.g. for creating cycles.

  5. abstract class Dispatcher extends ExecutionContextExecutor
  6. abstract class Dispatchers extends AnyRef
  7. final class Drain [-T, +R] extends AnyRef

    A Drain is a streaming component] with one input port and no output port.

    A Drain is a streaming component] with one input port and no output port. As such it serves as a "point of exit" from a stream graph to other destinations (e.g. to memory, disk or the network).

    T

    the type of the data elements consumed

    R

    the type of "results" that the drain provides

  8. trait Extension extends AnyRef
  9. trait ExtensionId [T <: Extension] extends AnyRef
  10. final class IllegalAsyncBoundaryException extends RuntimeException
  11. final class IllegalReuseException extends RuntimeException
  12. final class IllegalStreamSetupException extends RuntimeException
  13. abstract class Module [I <: Input, O <: Output] extends AnyRef

    A Streaming Component with up to four interfaces:

    A Streaming Component with up to four interfaces:

    • A Top input
    • A Top output
    • A Bottom input
    • A Bottom output

    IT OT ┌──▼──┬──▲──┐ │ │ │ │ │ │ └──▼──┴──▲──┘ OB IB

    A Module without output interfaces might produce a result of type R.

  14. final class Pipe [-A, +B] extends StreamOps[B]
  15. final class PushSpout [+A] extends AnyRef

    A PushSpout provides a Spout that can be "manually" pushed into from the outside, potentially by several threads concurrently.

    A PushSpout provides a Spout that can be "manually" pushed into from the outside, potentially by several threads concurrently.

    It manages an internal queue which allows for compensation of some fluctuation in demand from downstream (i.e. backpressure). If the queue is full all further pushes are rejected, i.e. no elements are being dropped.

  16. final class RunnableStreamGraph [+A] extends AnyRef

    R RunnableStreamGraph represents a stream graph that has already been sealed and that is ready to be run.

    R RunnableStreamGraph represents a stream graph that has already been sealed and that is ready to be run.

    If the type parameter A is a Future then run().result returns an A, otherwise a Try[A].

  17. trait Scheduler extends AnyRef
  18. sealed abstract class Split extends AnyRef
  19. final class Spout [+A] extends StreamOps[A]

    A Spout is a streaming component with no input port and a single output port.

    A Spout is a streaming component with no input port and a single output port. As such it serves as a "point of entry" into a stream graph for data elements from other sources (e.g. from memory, disk or the network).

    A

    the type of the data elements produced

  20. abstract class Stage extends AnyRef
  21. abstract class StreamEnv extends AnyRef
  22. sealed abstract class StreamEvent [+T] extends AnyRef
  23. final class StreamGraph [+A] extends AnyRef

    A StreamGraph represents a stream graph in which the ports of all stages have been properly connected and which is therefore ready to be started.

    A StreamGraph represents a stream graph in which the ports of all stages have been properly connected and which is therefore ready to be started.

    If the type parameter A is a Future then run().result returns an A, otherwise a Try[A].

  24. final case class StreamLimitExceeded (max: Long, offendingElem: Any) extends RuntimeException with Product with Serializable

    The RuntimeException thrown by the limit operation.

  25. abstract class StreamOps [A] extends AnyRef

    Defines all the transformations that are available on Spout, Pipe and fan-out sub-streams.

  26. final class StreamRun [+A] extends AnyRef

    A StreamRun represents a stream graph that has already been started and thus is either running or has already terminated.

    A StreamRun represents a stream graph that has already been started and thus is either running or has already terminated.

    A

    the type of the result member

  27. final class StreamTimeoutException extends RuntimeException
  28. abstract class Streamable [-T] extends AnyRef
    Annotations
    @implicitNotFound( ... )
  29. final class SubStreamStartTimeoutException extends RuntimeException
  30. final class UnclosedStreamGraphException extends RuntimeException
  31. final class UnsupportedSecondSubscriptionException extends RuntimeException
  32. final class UnterminatedSynchronousStreamException extends RuntimeException

    The Exception that is thrown when a synchronous stream stops running without having been properly terminated.

Ungrouped