final class Pipe[-A, +B] extends StreamOps[B]

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

Type Members

  1. type Repr[T] = Pipe[A, T]
    Definition Classes
    PipeStreamOps
  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 >: B @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
    Definition Classes
    PipeStreamOps
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. final def async(dispatcherId: String = ""): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  8. final def asyncBoundary(dispatcherId: String = "", bufferSize: Int = 32): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  9. final def attach[L <: HList, S, SS](fanIn: Spout.FanIn[L, S] forSome {type _$4})(implicit ev: Lub[B @scala.annotation.unchecked.uncheckedVariance, S, SS]): FanIn[::[B @scala.annotation.unchecked.uncheckedVariance, L], SS]
    Definition Classes
    StreamOps
  10. final def attach[L <: HList, S](branchOut: Spout.BranchOut[L, _$2, _$3] forSome {type _$1, type _$2, type _$3})(implicit u: Aux[::[B @scala.annotation.unchecked.uncheckedVariance, L], S]): FanIn[::[B @scala.annotation.unchecked.uncheckedVariance, L], S]
    Definition Classes
    StreamOps
  11. final def attach[T, S, O](sub: Spout[T])(implicit ev: Lub[B @scala.annotation.unchecked.uncheckedVariance, T, O]): FanIn[::[B @scala.annotation.unchecked.uncheckedVariance, ::[T, HNil]], O]
    Definition Classes
    StreamOps
  12. final def attachAll[SS, S >: B @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[B @scala.annotation.unchecked.uncheckedVariance, T, O]): FanIn[::[T, ::[B @scala.annotation.unchecked.uncheckedVariance, HNil]], O]
    Definition Classes
    StreamOps
  14. final def attachN[T, O](n: Nat, fo: Spout.FanOut[_, _])(implicit f: Fill[N, T], ti: ToInt[N], lub: Lub[B @scala.annotation.unchecked.uncheckedVariance, T, O]): FanIn[::[B @scala.annotation.unchecked.uncheckedVariance, Out], O]
    Definition Classes
    StreamOps
  15. def base: Inport
    Attributes
    protected
    Definition Classes
    PipeStreamOps
  16. final def buffer(size: Int, requestStrategy: RequestStrategy = ...): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  17. final def bufferDropping(size: Int, overflowStrategy: OverflowStrategy): Repr[B @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[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
  20. final def concat[B >: B @scala.annotation.unchecked.uncheckedVariance](other: Spout[B]): Repr[B]
    Definition Classes
    StreamOps
  21. final def conflate[B >: B @scala.annotation.unchecked.uncheckedVariance](aggregate: (B, B @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  22. final def conflateToLast[B >: B @scala.annotation.unchecked.uncheckedVariance]: Repr[B]
    Definition Classes
    StreamOps
  23. final def conflateWithSeed[B](lift: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ B)(aggregate: (B, B @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  24. final def deduplicate: Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  25. final def delay(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  26. final def drop(n: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  27. final def dropAll: Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  28. final def dropLast(n: Int): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  29. final def dropWhile(predicate: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  30. final def dropWithin(d: FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  31. final def duplicate: Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  32. final def elementAt(index: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  33. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  34. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  35. final def expand[B](zero: Iterator[B], extrapolate: (B @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
  36. final def expand[B](extrapolate: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Iterator[B]): Repr[B]
    Definition Classes
    StreamOps
  37. final def expand(): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  38. final def fanOutBroadcast(bufferSize: Int = 0, requestStrategy: RequestStrategy = ..., eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
  39. final def fanOutRoundRobin(eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  40. final def fanOutSequential(eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  41. final def fanOutSwitch[N <: Nat](f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Int, eagerCancel: Boolean)(implicit ti: ToInt[N], fl: Fill[N, B @scala.annotation.unchecked.uncheckedVariance]): BranchOut[Out, HNil, Nothing]
    Definition Classes
    StreamOps
  42. final def fanOutSwitch[N <: Nat](f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Int)(implicit ti: ToInt[N], fl: Fill[N, B @scala.annotation.unchecked.uncheckedVariance]): BranchOut[Out, HNil, Nothing]
    Definition Classes
    StreamOps
  43. final def fanOutSwitch(n: Nat, eagerCancel: Boolean = false)(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Int)(implicit ti: ToInt[N], fl: Fill[N, B @scala.annotation.unchecked.uncheckedVariance]): BranchOut[Out, HNil, Nothing]
    Definition Classes
    StreamOps
  44. final def fanOutToAny(eagerCancel: Boolean = false): FanOut[HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  45. final def fanOutUnZip[L <: HList](eagerCancel: Boolean = false)(implicit ev: FromProduct[B @scala.annotation.unchecked.uncheckedVariance, L]): BranchOut[L, HNil, Nothing]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  46. final def filter[T](implicit classTag: ClassTag[T]): Repr[T]
    Definition Classes
    StreamOps
  47. final def filter(predicate: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  48. final def filterNot(predicate: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  49. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  50. final def first: Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  51. final def flatMap[B, C](f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ B, parallelism: Int = 1)(implicit ev: Aux[B, C]): Repr[C]
    Definition Classes
    StreamOps
  52. final def flattenConcat[B](parallelism: Int = 1)(implicit ev: Aux[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
  53. final def flattenMerge[B](parallelism: Int)(implicit ev: Aux[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
  54. final def flattenRoundRobin[B](parallelism: Int)(implicit ev: Aux[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  55. final def flattenSorted[B](parallelism: Int)(implicit arg0: Ordering[B], ev: Aux[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  56. final def flattenToSeq[B](parallelism: Int)(implicit ev: Aux[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[Seq[B]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  57. final def fold[B](zero: B)(f: (B, B @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  58. final def foldAsync[B](zero: B)(f: (B, B @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  59. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  60. final def groupBy[K](maxSubstreams: Int, reopenCancelledSubs: Boolean = false, eagerComplete: Boolean = false)(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ K): Repr[Spout[B @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
  61. final def grouped(groupSize: Int, emitSingleEmpty: Boolean = false): Repr[Seq[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  62. final def groupedTo[M[+_]](groupSize: Int, emitSingleEmpty: Boolean = false)(implicit cbf: CanBuildFrom[M[B @scala.annotation.unchecked.uncheckedVariance], B @scala.annotation.unchecked.uncheckedVariance, M[B @scala.annotation.unchecked.uncheckedVariance]]): Repr[M[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  63. final def groupedWithin(maxSize: Int, duration: FiniteDuration): Repr[Vector[B @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
  64. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  65. final def headAndTail: Repr[(B @scala.annotation.unchecked.uncheckedVariance, Spout[B @scala.annotation.unchecked.uncheckedVariance])]
    Definition Classes
    StreamOps
  66. def identity: Repr[B @scala.annotation.unchecked.uncheckedVariance]

    The underlying representation without additional stage appended.

    The underlying representation without additional stage appended.

    Definition Classes
    StreamOps
  67. final def injectBroadcast(parallelism: Int): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  68. final def injectRoundRobin(parallelism: Int): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  69. final def injectSequential(bufferSize: Int = 1): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  70. final def injectToAny(parallelism: Int): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  71. def inputAsDrain: Drain[A, Unit]
  72. final def interleave[B >: B @scala.annotation.unchecked.uncheckedVariance](other: Spout[B], segmentSize: Int = 1, eagerComplete: Boolean = false): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  73. final def intersperse[B >: B @scala.annotation.unchecked.uncheckedVariance](start: B, inject: B, end: B): Repr[B]
    Definition Classes
    StreamOps
  74. final def intersperse[B >: B @scala.annotation.unchecked.uncheckedVariance](inject: B): Repr[B]
    Definition Classes
    StreamOps
  75. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  76. final def last: Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  77. final def logSignal(marker: String, log: (String, StreamEvent[B @scala.annotation.unchecked.uncheckedVariance]) ⇒ Unit = defaultLogSignal): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  78. final def map[B](f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  79. final def mapAsync[B](parallelism: Int)(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
  80. final def mapAsyncUnordered[B](parallelism: Int)(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
  81. final def merge[B >: B @scala.annotation.unchecked.uncheckedVariance](other: Spout[B], eagerComplete: Boolean = false): Repr[B]
    Definition Classes
    StreamOps
  82. final def mergeSorted[B >: B @scala.annotation.unchecked.uncheckedVariance](other: Spout[B], eagerComplete: Boolean = false)(implicit arg0: Ordering[B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  83. final def mergeToEither[B](right: Spout[B]): Repr[Either[B @scala.annotation.unchecked.uncheckedVariance, B]]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  84. final def multiply(factor: Int): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  85. def named(moduleID: ID): Pipe.this.type
  86. def named(name: String): Pipe.this.type
  87. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  88. final def nop: Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  89. final def notify(): Unit
    Definition Classes
    AnyRef
  90. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  91. final def onCancel(callback: ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  92. final def onComplete(callback: ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  93. final def onElement(callback: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  94. final def onError(callback: (Throwable) ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  95. final def onRequest(callback: (Int) ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  96. final def onSignal(callback: (StreamEvent[B @scala.annotation.unchecked.uncheckedVariance]) ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  97. final def onSignalPF(callback: PartialFunction[StreamEvent[B @scala.annotation.unchecked.uncheckedVariance], Unit]): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  98. final def onStart(callback: () ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  99. final def onTerminate(callback: (Option[Throwable]) ⇒ Unit): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  100. final def orElse[B >: B @scala.annotation.unchecked.uncheckedVariance](other: Spout[B]): Repr[B]
    Definition Classes
    StreamOps
  101. def outputAsSpout: Spout[B]
  102. final def prefixAndTail(n: Int): Repr[(Seq[B @scala.annotation.unchecked.uncheckedVariance], Spout[B @scala.annotation.unchecked.uncheckedVariance])]
    Definition Classes
    StreamOps
  103. final def prefixAndTailTo[S[+_]](n: Int)(implicit cbf: CanBuildFrom[S[B @scala.annotation.unchecked.uncheckedVariance], B @scala.annotation.unchecked.uncheckedVariance, S[B @scala.annotation.unchecked.uncheckedVariance]]): Repr[(S[B @scala.annotation.unchecked.uncheckedVariance], Spout[B @scala.annotation.unchecked.uncheckedVariance])]
    Definition Classes
    StreamOps
  104. final def protect[B](recreate: (Option[Throwable]) ⇒ Pipe[B @scala.annotation.unchecked.uncheckedVariance, B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  105. final def recover[B >: B @scala.annotation.unchecked.uncheckedVariance](pf: PartialFunction[Throwable, B]): Repr[B]
    Definition Classes
    StreamOps
  106. final def recoverToTry: Repr[Try[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  107. final def recoverWith[B >: B @scala.annotation.unchecked.uncheckedVariance](maxRecoveries: Long)(pf: PartialFunction[Throwable, Spout[B]]): Repr[B]
    Definition Classes
    StreamOps
  108. final def reduce[B >: B @scala.annotation.unchecked.uncheckedVariance](f: (B, B) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  109. final def sample(d: FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  110. final def scan[B](zero: B)(f: (B, B @scala.annotation.unchecked.uncheckedVariance) ⇒ B): Repr[B]
    Definition Classes
    StreamOps
  111. final def scanAsync[B](zero: B)(f: (B, B @scala.annotation.unchecked.uncheckedVariance) ⇒ Future[B]): Repr[B]
    Definition Classes
    StreamOps
    Annotations
    @compileTimeOnly( "Not yet implemented" )
  112. final def slice(startIndex: Long, length: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  113. final def sliceEvery(dropLen: Long, takeLen: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  114. final def sliding(windowSize: Int): Repr[Seq[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  115. final def slidingTo[M[+_]](windowSize: Int)(implicit cbf: CanBuildFrom[M[B @scala.annotation.unchecked.uncheckedVariance], B @scala.annotation.unchecked.uncheckedVariance, M[B @scala.annotation.unchecked.uncheckedVariance]], ev: <:<[M[B @scala.annotation.unchecked.uncheckedVariance], Seq[B @scala.annotation.unchecked.uncheckedVariance]]): Repr[M[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  116. final def split(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Command, eagerCancel: Boolean = true): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  117. final def splitAfter(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean, eagerCancel: Boolean = true): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  118. final def splitWhen(f: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean, eagerCancel: Boolean = true): Repr[Spout[B @scala.annotation.unchecked.uncheckedVariance]]
    Definition Classes
    StreamOps
  119. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  120. final def take(count: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  121. final def takeEveryNth(n: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  122. final def takeLast(n: Int): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  123. final def takeWhile(predicate: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Boolean): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  124. final def takeWithin(d: FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  125. final def tee(drain: Drain[B @scala.annotation.unchecked.uncheckedVariance, Unit], eagerCancel: Boolean = false): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  126. final def throttle(cost: Int, per: FiniteDuration, burst: Int, costFn: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Int): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  127. final def throttle(elements: Int, per: FiniteDuration, burst: Int = 1): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  128. def to[R](drain: Drain[B, R]): Drain[A, R]
  129. def toProcessor: StreamGraph[Processor[A, B]]
  130. def toString(): String
    Definition Classes
    AnyRef → Any
  131. def via[P <: HList, R, Out](joined: Joined[::[B, HNil], P, R])(vr: ViaResult[P, Drain[A, R], Repr, Out]): Out
  132. def via[C](pipe: Pipe[B, C]): Repr[C]
    Definition Classes
    PipeStreamOps
  133. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  134. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  135. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  136. final def withCompletionTimeout(timeout: FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  137. final def withIdleTimeout(timeout: FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  138. final def withInitialTimeout(timeout: FiniteDuration): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  139. final def withLimit(maxElements: Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  140. final def withLimitWeighted(max: Long, cost: (B @scala.annotation.unchecked.uncheckedVariance) ⇒ Long): Repr[B @scala.annotation.unchecked.uncheckedVariance]
    Definition Classes
    StreamOps
  141. def wrap[T](inport: Inport): Repr[T]
    Attributes
    protected
    Definition Classes
    PipeStreamOps
  142. final def zip[B](other: Spout[B]): Repr[(B @scala.annotation.unchecked.uncheckedVariance, B)]
    Definition Classes
    StreamOps

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

Inherited from AnyRef

Inherited from Any

Ungrouped