final class Spout[+A] extends StreamOps[A]

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

Linear Supertypes
StreamOps[A @scala.annotation.unchecked.uncheckedVariance], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Spout
  2. StreamOps
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Spout(inport: Inport)

Type Members

  1. type Repr[T] = Spout[T]
    Definition Classes
    SpoutStreamOps
  2. final class BranchOut [AA <: HList, L <: HList, S] extends FanIn[L, S]

    Closed fan-out, where the number of fan-out sub streams and their (potentially differing) types are predefined.

    Closed fan-out, where the number of fan-out sub streams and their (potentially differing) types are predefined.

    AA

    element types of the still unconsumed fan-out sub-streams as an HList

    L

    element types of all unterminated fan-in sub-streams as an HList

    S

    super-type of all unterminated fan-in sub-streams

    Definition Classes
    StreamOps
  3. sealed class FanIn [L <: HList, S] extends AnyRef

    Heterogeneous fan-in, where the fan-in streams have potentially differing types.

    Heterogeneous fan-in, where the fan-in streams have potentially differing types.

    L

    element types of all unterminated fan-in sub-streams as an HList

    S

    super-type of all unterminated fan-in sub-streams

    Definition Classes
    StreamOps
  4. final class FanIn0 [S] extends AnyRef

    Homogeneous fan-in, where all fan-in streams have the same type.

    Homogeneous fan-in, where all fan-in streams have the same type.

    S

    super-type of all fan-in sub-streams

    Definition Classes
    StreamOps
  5. final class FanOut [L <: HList, S] extends FanIn[L, S]

    Open fan-out, where all fan-out sub streams have the same type and there can be arbitrarily many of them.

    Open fan-out, where all fan-out sub streams have the same type and there can be arbitrarily many of them.

    L

    element types of all unterminated fan-in sub-streams as an HList

    S

    super-type of all unterminated fan-in sub-streams

    Definition Classes
    StreamOps

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ++[B >: A @scala.annotation.unchecked.uncheckedVariance](other: Spout[B]): Repr[B]
    Definition Classes
    StreamOps
  4. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  5. def append[T](stage: StageImpl): Repr[T]
    Attributes
    protected[swave.core]
    Definition Classes
    SpoutStreamOps
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. final def async(dispatcherId: String = ""): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  8. final def asyncBoundary(dispatcherId: String = "", bufferSize: Int = 32): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  9. final def attach[L <: HList, S, SS](fanIn: FanIn[L, S] forSome {type _$4})(implicit ev: Lub[A @scala.annotation.unchecked.uncheckedVariance, S, SS]): FanIn[::[A @scala.annotation.unchecked.uncheckedVariance, L], SS]
    Definition Classes
    StreamOps
  10. final def attach[L <: HList, S](branchOut: BranchOut[L, _$2, _$3] forSome {type _$1, type _$2, type _$3})(implicit u: Aux[::[A @scala.annotation.unchecked.uncheckedVariance, L], S]): FanIn[::[A @scala.annotation.unchecked.uncheckedVariance, L], S]
    Definition Classes
    StreamOps
  11. final def attach[T, S, O](sub: Spout[T])(implicit ev: Lub[A @scala.annotation.unchecked.uncheckedVariance, T, O]): FanIn[::[A @scala.annotation.unchecked.uncheckedVariance, ::[T, HNil]], O]
    Definition Classes
    StreamOps
  12. final def attachAll[SS, S >: A @scala.annotation.unchecked.uncheckedVariance](subs: Traversable[SS])(implicit ev: Aux[SS, S]): FanIn0[S]
    Definition Classes
    StreamOps
  13. final def attachLeft[T, S, O](sub: Spout[T])(implicit ev: Lub[A @scala.annotation.unchecked.uncheckedVariance, T, O]): FanIn[::[T, ::[A @scala.annotation.unchecked.uncheckedVariance, HNil]], O]
    Definition Classes
    StreamOps
  14. final def attachN[T, O](n: Nat, fo: FanOut[_, _])(implicit f: Fill[N, T], ti: ToInt[N], lub: Lub[A @scala.annotation.unchecked.uncheckedVariance, T, O]): FanIn[::[A @scala.annotation.unchecked.uncheckedVariance, Out], O]
    Definition Classes
    StreamOps
  15. def base: Inport
    Attributes
    protected
    Definition Classes
    SpoutStreamOps
  16. final def buffer(size: Int, requestStrategy: RequestStrategy = ...): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  17. final def bufferDropping(size: Int, overflowStrategy: OverflowStrategy): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  18. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def collect[B](pf: PartialFunction[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
  20. final def concat[B >: A @scala.annotation.unchecked.uncheckedVariance](other: Spout[B]): Repr[B]
    Definition Classes
    StreamOps
  21. final def conflate[B >: A @scala.annotation.unchecked.uncheckedVariance](aggregate: (B, A @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  22. final def conflateToLast[B >: A @scala.annotation.unchecked.uncheckedVariance]: Repr[B]
    Definition Classes
    StreamOps
  23. final def conflateWithSeed[B](lift: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ B)(aggregate: (B, A @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  24. final def deduplicate: Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  25. final def delay(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  26. def drainFolding[R](zero: R)(f: (R, A) ⇒ R)(implicit env: StreamEnv): Future[R]

    Attaches a Drain which applies the given folding function across all elements produced by the stream.

    Attaches a Drain which applies the given folding function across all elements produced by the stream. The stream is immediately started.

  27. def drainTo[R](drain: Drain[A, R])(implicit env: StreamEnv, ev: ToTryOrFuture[R]): Out

    Attaches the given Drain and immediately starts the stream.

  28. def drainToBlackHole()(implicit env: StreamEnv): Future[Unit]

    Attaches a Drain which requests and drops all elements produced by the stream.

    Attaches a Drain which requests and drops all elements produced by the stream. The stream is therefore only run for its side-effects.

  29. def drainToHead()(implicit env: StreamEnv): Future[A]

    Attaches a Drain which produces the first element as result and immediately starts the stream.

  30. def drainToLast()(implicit env: StreamEnv): Future[A]

    Attaches a Drain which produces the last element as result and immediately starts the stream.

  31. def drainToList(limit: Int)(implicit env: StreamEnv): Future[List[A]]

    Attaches a Drain which collects all incoming elements into a List and immediately starts the stream.

    Attaches a Drain which collects all incoming elements into a List and immediately starts the stream. If the stream produces more than limit elements it will be error-terminated with a StreamLimitExceeded exception.

  32. def drainToMkString(limit: Int, start: String, sep: String, end: String)(implicit env: StreamEnv): Future[String]

    Attaches a Drain which produces a single string representation of all stream elements.

    Attaches a Drain which produces a single string representation of all stream elements. If the stream produces more than limit elements it will be error-terminated with a StreamLimitExceeded exception. The stream is immediately started.

  33. def drainToMkString(limit: Int, sep: String = "")(implicit env: StreamEnv): Future[String]

    Attaches a Drain which produces a single string representation of all stream elements.

    Attaches a Drain which produces a single string representation of all stream elements. If the stream produces more than limit elements it will be error-terminated with a StreamLimitExceeded exception. The stream is immediately started.

  34. def drainToSeq[M[+_]](limit: Int)(implicit env: StreamEnv, cbf: CanBuildFrom[M[A], A, M[A]]): Future[M[A]]

    Attaches a Drain which collects all incoming elements into a container type and immediately starts the stream.

    Attaches a Drain which collects all incoming elements into a container type and immediately starts the stream. If the stream produces more than limit elements it will be error-terminated with a StreamLimitExceeded exception.

  35. def drainToVector(limit: Int)(implicit env: StreamEnv): Future[Vector[A]]

    Attaches a Drain which collects all incoming elements into a Vector and immediately starts the stream.

    Attaches a Drain which collects all incoming elements into a Vector and immediately starts the stream. If the stream produces more than limit elements it will be error-terminated with a StreamLimitExceeded exception.

  36. final def drop(n: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  37. final def dropAll: Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  38. final def dropLast(n: Int): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  39. final def dropWhile(predicate: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  40. final def dropWithin(d: FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  41. final def duplicate: Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  42. final def elementAt(index: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  43. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  44. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  45. final def expand[B](zero: Iterator[B], extrapolate: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Iterator[B]): Repr[B]

    Rate-detaches the downstream from the upstream by allowing the downstream to consume elements faster than the upstream produces them.

    Rate-detaches the downstream from the upstream by allowing the downstream to consume elements faster than the upstream produces them. Each element coming in from upstream is passed through the given extrapolate function. The produced iterator is then pulled from at least once (if non-empty). Afterwards, if the downstream is ready to consume more elements but the upstream hasn't delivered any yet the iterator will be drained until it has no more elements or the next element from upstream arrives.

    If the upstream produces elements at a faster rate than the downstream can consume them each iterator produced by the extrapolate function will only ever have its first element pulled and the upstream will be backpressured, i.e. the downstream will slow down the upstream.

    zero

    iterator used for supplying elements to downstream before the first element arrives from upstream, only pulled from if the first demand from downstream arrives before the first element from upstream.

    extrapolate

    function producing the elements that each element from upstream is expanded to

    Definition Classes
    StreamOps
  46. final def expand[B](extrapolate: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Iterator[B]): Repr[B]
    Definition Classes
    StreamOps
  47. final def expand(): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  48. final def fanOutBroadcast(bufferSize: Int = 0, requestStrategy: RequestStrategy = ..., eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
  49. final def fanOutRoundRobin(eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  50. final def fanOutSequential(eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  51. final def fanOutSwitch[N <: Nat](f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Int, eagerCancel: Boolean)(implicit ti: ToInt[N], fl: Fill[N, A @scala.annotation.unchecked.uncheckedVariance]): BranchOut[Out, HNil, Nothing]
    Definition Classes
    StreamOps
  52. final def fanOutSwitch[N <: Nat](f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Int)(implicit ti: ToInt[N], fl: Fill[N, A @scala.annotation.unchecked.uncheckedVariance]): BranchOut[Out, HNil, Nothing]
    Definition Classes
    StreamOps
  53. final def fanOutSwitch(n: Nat, eagerCancel: Boolean = false)(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Int)(implicit ti: ToInt[N], fl: Fill[N, A @scala.annotation.unchecked.uncheckedVariance]): BranchOut[Out, HNil, Nothing]
    Definition Classes
    StreamOps
  54. final def fanOutToAny(eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  55. final def fanOutUnZip[L <: HList](eagerCancel: Boolean = false)(implicit ev: FromProduct[A @scala.annotation.unchecked.uncheckedVariance, L]): BranchOut[L, HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  56. final def filter[T](implicit classTag: ClassTag[T]): Repr[T]
    Definition Classes
    StreamOps
  57. final def filter(predicate: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  58. final def filterNot(predicate: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  59. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  60. final def first: Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  61. final def flatMap[B, C](f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ B, parallelism: Int = 1)(implicit ev: Aux[B, C]): Repr[C]
    Definition Classes
    StreamOps
  62. final def flattenConcat[B](parallelism: Int = 1)(implicit ev: Aux[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
  63. final def flattenMerge[B](parallelism: Int)(implicit ev: Aux[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
  64. final def flattenRoundRobin[B](parallelism: Int)(implicit ev: Aux[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  65. final def flattenSorted[B](parallelism: Int)(implicit arg0: Ordering[B], ev: Aux[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  66. final def flattenToSeq[B](parallelism: Int)(implicit ev: Aux[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[Seq[B]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  67. final def fold[B](zero: B)(f: (B, A @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  68. final def foldAsync[B](zero: B)(f: (B, A @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  69. def foreach(callback: (A) ⇒ Unit)(implicit env: StreamEnv): Future[Unit]

    Attaches a Drain which executes the given callback for all stream elements and immediately starts the stream.

  70. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  71. final def groupBy[K](maxSubstreams: Int, reopenCancelledSubs: Boolean = false, eagerComplete: Boolean = false)(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ K): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]

    maxSubstreams

    the maximum number of sub-streams allowed. Exceeding this limit causes to stream to be completed with an IllegalStateException.

    reopenCancelledSubs

    if true cancellation of a sub-stream will trigger a new sub-stream for the respective key to be emitted to the downstream (whenever a respective element arrives), if false all elements that are keyed to a cancelled sub-stream will simply be dropped

    eagerComplete

    if true the cancellation of the (main) downstream will immediately be propagated to upstream and all sub-stream will be completed, if false the cancellation of the (main) downstream will keep the stream running, but cause all elements keyed to not yet open sub-streams to be dropped.

    f

    the key function. Must not return null for any element. Otherwise the stream is completed with a RuntimeException.

    Definition Classes
    StreamOps
  72. final def grouped(groupSize: Int, emitSingleEmpty: Boolean = false): Repr[Seq[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  73. final def groupedTo[M[+_]](groupSize: Int, emitSingleEmpty: Boolean = false)(implicit cbf: CanBuildFrom[M[A @scala.annotation.unchecked.uncheckedVariance], A @scala.annotation.unchecked.uncheckedVariance, M[A @scala.annotation.unchecked.uncheckedVariance]]): Repr[M[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  74. final def groupedWithin(maxSize: Int, duration: FiniteDuration): Repr[Vector[A @scala.annotation.unchecked.uncheckedVariance]]

    Groups incoming elements received within the given duration into Vector instances that have at least one and at most maxSize elements.

    Groups incoming elements received within the given duration into Vector instances that have at least one and at most maxSize elements. A group is emitted when maxSize has been reached or the duration since the last emit has expired. If no elements are received within the duration then nothing is emitted at time expiration, but the next incoming element will be emitted immediately after reception as part of a single-element group.

    maxSize

    the maximum size of the emitted Vector instances, must be > 0

    duration

    the time period over which to aggregate, must be > 0

    Definition Classes
    StreamOps
  75. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  76. final def headAndTail: Repr[(A @scala.annotation.unchecked.uncheckedVariance, Spout[A @scala.annotation.unchecked.uncheckedVariance])]
    Definition Classes
    StreamOps
  77. def identity: Repr[A @scala.annotation.unchecked.uncheckedVariance]

    The underlying representation without additional stage appended.

    The underlying representation without additional stage appended.

    Definition Classes
    StreamOps
  78. final def injectBroadcast(parallelism: Int): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  79. final def injectRoundRobin(parallelism: Int): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  80. final def injectSequential(bufferSize: Int = 1): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  81. final def injectToAny(parallelism: Int): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  82. final def interleave[B >: A @scala.annotation.unchecked.uncheckedVariance](other: Spout[B], segmentSize: Int = 1, eagerComplete: Boolean = false): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  83. final def intersperse[B >: A @scala.annotation.unchecked.uncheckedVariance](start: B, inject: B, end: B): Repr[B]
    Definition Classes
    StreamOps
  84. final def intersperse[B >: A @scala.annotation.unchecked.uncheckedVariance](inject: B): Repr[B]
    Definition Classes
    StreamOps
  85. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  86. final def last: Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  87. final def logSignal(marker: String, log: (String, StreamEvent[A @scala.annotation.unchecked.uncheckedVariance]) ⇒ Unit = defaultLogSignal): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  88. final def map[B](f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  89. final def mapAsync[B](parallelism: Int)(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
  90. final def mapAsyncUnordered[B](parallelism: Int)(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
  91. final def merge[B >: A @scala.annotation.unchecked.uncheckedVariance](other: Spout[B], eagerComplete: Boolean = false): Repr[B]
    Definition Classes
    StreamOps
  92. final def mergeSorted[B >: A @scala.annotation.unchecked.uncheckedVariance](other: Spout[B], eagerComplete: Boolean = false)(implicit arg0: Ordering[B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  93. final def mergeToEither[B](right: Spout[B]): Repr[Either[A @scala.annotation.unchecked.uncheckedVariance, B]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  94. final def multiply(factor: Int): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  95. def named(name: String): Spout.this.type

    Explicitly attaches the given name to this Spout.

  96. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  97. final def nop: Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  98. final def notify(): Unit
    Definition Classes
    AnyRef
  99. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  100. final def onCancel(callback: ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  101. final def onComplete(callback: ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  102. final def onElement(callback: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  103. final def onError(callback: (Throwable) ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  104. final def onRequest(callback: (Int) ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  105. final def onSignal(callback: (StreamEvent[A @scala.annotation.unchecked.uncheckedVariance]) ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  106. final def onSignalPF(callback: PartialFunction[StreamEvent[A @scala.annotation.unchecked.uncheckedVariance], Unit]): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  107. final def onStart(callback: () ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  108. final def onTerminate(callback: (Option[Throwable]) ⇒ Unit): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  109. final def orElse[B >: A @scala.annotation.unchecked.uncheckedVariance](other: Spout[B]): Repr[B]
    Definition Classes
    StreamOps
  110. final def prefixAndTail(n: Int): Repr[(Seq[A @scala.annotation.unchecked.uncheckedVariance], Spout[A @scala.annotation.unchecked.uncheckedVariance])]
    Definition Classes
    StreamOps
  111. final def prefixAndTailTo[S[+_]](n: Int)(implicit cbf: CanBuildFrom[S[A @scala.annotation.unchecked.uncheckedVariance], A @scala.annotation.unchecked.uncheckedVariance, S[A @scala.annotation.unchecked.uncheckedVariance]]): Repr[(S[A @scala.annotation.unchecked.uncheckedVariance], Spout[A @scala.annotation.unchecked.uncheckedVariance])]
    Definition Classes
    StreamOps
  112. final def protect[B](recreate: (Option[Throwable]) ⇒ Pipe[A @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  113. final def recover[B >: A @scala.annotation.unchecked.uncheckedVariance](pf: PartialFunction[Throwable, B]): Repr[B]
    Definition Classes
    StreamOps
  114. final def recoverToTry: Repr[Try[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  115. final def recoverWith[B >: A @scala.annotation.unchecked.uncheckedVariance](maxRecoveries: Long)(pf: PartialFunction[Throwable, Spout[B]]): Repr[B]
    Definition Classes
    StreamOps
  116. final def reduce[B >: A @scala.annotation.unchecked.uncheckedVariance](f: (B, B) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  117. final def sample(d: FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  118. final def scan[B](zero: B)(f: (B, A @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  119. final def scanAsync[B](zero: B)(f: (B, A @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  120. final def slice(startIndex: Long, length: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  121. final def sliceEvery(dropLen: Long, takeLen: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  122. final def sliding(windowSize: Int): Repr[Seq[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  123. final def slidingTo[M[+_]](windowSize: Int)(implicit cbf: CanBuildFrom[M[A @scala.annotation.unchecked.uncheckedVariance], A @scala.annotation.unchecked.uncheckedVariance, M[A @scala.annotation.unchecked.uncheckedVariance]], ev: <:<[M[A @scala.annotation.unchecked.uncheckedVariance], Seq[A @scala.annotation.unchecked.uncheckedVariance]]): Repr[M[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  124. final def split(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Command, eagerCancel: Boolean = true): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  125. final def splitAfter(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean, eagerCancel: Boolean = true): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  126. final def splitWhen(f: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean, eagerCancel: Boolean = true): Repr[Spout[A @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  127. def stage: Stage

    The Stage of this spout.

  128. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  129. final def take(count: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  130. final def takeEveryNth(n: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  131. final def takeLast(n: Int): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  132. final def takeWhile(predicate: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  133. final def takeWithin(d: FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  134. final def tee(drain: Drain[A @scala.annotation.unchecked.uncheckedVariance, Unit], eagerCancel: Boolean = false): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  135. final def throttle(cost: Int, per: FiniteDuration, burst: Int, costFn: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Int): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  136. final def throttle(elements: Int, per: FiniteDuration, burst: Int = 1): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  137. def to[R](drain: Drain[A, R]): StreamGraph[R]

    Attaches the given Drain to close this part of the stream graph.

  138. def toString(): String
    Definition Classes
    AnyRef → Any
  139. def via[P <: HList, R, Out](joined: Joined[::[A, HNil], P, R])(vr: ViaResult[P, StreamGraph[R], Spout, Out]): Out

    Attaches the given Module and returns the resulting structure.

  140. def via[B](pipe: Pipe[A, B]): Repr[B]

    Attaches the given Pipe and returns a transformed Spout.

    Attaches the given Pipe and returns a transformed Spout.

    Definition Classes
    SpoutStreamOps
  141. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  142. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  143. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  144. final def withCompletionTimeout(timeout: FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  145. final def withIdleTimeout(timeout: FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  146. final def withInitialTimeout(timeout: FiniteDuration): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  147. final def withLimit(maxElements: Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  148. final def withLimitWeighted(max: Long, cost: (A @scala.annotation.unchecked.uncheckedVariance) ⇒ Long): Repr[A @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  149. def wrap[T](inport: Inport): Repr[T]
    Attributes
    protected
    Definition Classes
    SpoutStreamOps
  150. final def zip[B](other: Spout[B]): Repr[(A @scala.annotation.unchecked.uncheckedVariance, B)]
    Definition Classes
    StreamOps

Inherited from StreamOps[A @scala.annotation.unchecked.uncheckedVariance]

Inherited from AnyRef

Inherited from Any

Ungrouped