object Drain

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

Type Members

  1. sealed abstract class Capture [-R, P] extends AnyRef
  2. sealed abstract class Capture0 extends AnyRef

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 asyncParallelForeach[T](parallelism: Int)(f: (T) ⇒ Future[Unit])(implicit ec: ExecutionContext): Drain[T, Future[Unit]]

    Same as parallelForeach but for longer-running callbacks, which signal callback completion not by simply returning from the callback function (as in the case of parallelForeach) but rather via completion of the returned future.

    Same as parallelForeach but for longer-running callbacks, which signal callback completion not by simply returning from the callback function (as in the case of parallelForeach) but rather via completion of the returned future.

    CAUTION: The given callback might be called from several threads concurrently!

  6. def cancelling[T]: Drain[T, Unit]

    A Drain which signals no demand but immediately cancels its upstream and produces no result.

  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. def first[T](n: Int): Drain[T, Future[Seq[T]]]

    A Drain which demands n elements, collects them and produces an immutable.Seq.

  12. def fold[T, R](zero: R)(f: (R, T) ⇒ R): Drain[T, Future[R]]

    A Drain which signals infinite demand and executes the given folding function over the received elements.

    A Drain which signals infinite demand and executes the given folding function over the received elements.

    CAUTION: f will be called from another thread if the stream is asynchronous!

  13. def foreach[T](callback: (T) ⇒ Unit): Drain[T, Future[Unit]]

    A Drain which signals infinite demand and executes the given callback for each received element.

    A Drain which signals infinite demand and executes the given callback for each received element.

    CAUTION: callback will be called from another thread if the stream is asynchronous!

  14. def fromSubscriber[T](subscriber: Subscriber[T]): Drain[T, Unit]

    A Drain which drains the stream into the given Subscriber.

    A Drain which drains the stream into the given Subscriber. Both are directly linked to each other and thereby allow for connecting *swave* with other Reactive Streams implementations.

    The returned Drain instance cannot run synchronously.

  15. def generalSeq[M[+_], T](limit: Int)(implicit cbf: CanBuildFrom[M[T], T, M[T]]): Drain[T, Future[M[T]]]

    A Drain which signals demand of Integer.MAX_VALUE and buffers incoming elements in a collection of type M[+_].

    A Drain which signals demand of Integer.MAX_VALUE and buffers incoming elements in a collection of type M[+_]. The given limit protects against an overflow beyond the expected maximum number of elements by failing the stream with a StreamLimitExceeded if more elements are received.

  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  18. def head[T]: Drain[T, Future[T]]

    A Drain which only requests and produces the very first stream element.

    A Drain which only requests and produces the very first stream element. If the stream completes without having produced a single element the result future is completed with a NoSuchElementException.

  19. def headOption[T]: Drain[T, Future[Option[T]]]

    A Drain which only requests and produces the very first stream element as an Option.

  20. def ignore: Drain[Any, Future[Unit]]

    A Drain which signals infinite demand and simply drops all received elements.

    A Drain which signals infinite demand and simply drops all received elements. The produced Future is completed with the stream's termination.

  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. def last[T]: Drain[T, Future[T]]

    A Drain which signals infinite demand and drops all but the last of the received elements.

    A Drain which signals infinite demand and drops all but the last of the received elements. If the stream completes without having produced a single element the result future is completed with a NoSuchElementException.

  23. def lastOption[T]: Drain[T, Future[Option[T]]]

    A Drain which signals infinite demand and drops all but the last of the received elements, which it produces as an Option.

  24. def lazyStart[T, R](onStart: () ⇒ Drain[T, R])(implicit tf: ToFuture[R]): Drain[T, Future[Out]]

    A Drain which forwards the stream to the Drain instance returned by the given function.

    A Drain which forwards the stream to the Drain instance returned by the given function. The given function is only executed when the outer stream is started.

    If the outer stream is synchronous the Drain returned by onStart must be able to run synchronously as well. If it doesn't the stream will fail with an IllegalAsyncBoundaryException.

  25. def mkString[T](limit: Int, start: String, sep: String, end: String): Drain[T, Future[String]]

    A Drain which produces a single string representation of the stream by concatenating the toString result of all elements with the given start, sep and end strings.

    A Drain which produces a single string representation of the stream by concatenating the toString result of all elements with the given start, sep and end strings.

    The given limit protects against an overflow beyond the expected maximum number of elements by failing the stream with a StreamLimitExceeded if more elements are received.

  26. def mkString[T](limit: Int, sep: String = ""): Drain[T, Future[String]]

    A Drain which produces a single string representation of the stream by concatenating the toString result of all elements, optionally separated by sep.

    A Drain which produces a single string representation of the stream by concatenating the toString result of all elements, optionally separated by sep.

    The given limit protects against an overflow beyond the expected maximum number of elements by failing the stream with a StreamLimitExceeded if more elements are received.

  27. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. final def notify(): Unit
    Definition Classes
    AnyRef
  29. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  30. def parallelForeach[T](parallelism: Int)(f: (T) ⇒ Unit)(implicit ec: ExecutionContext): Drain[T, Future[Unit]]

    A Drain which signals infinite demand and executes the given callback for each received element.

    A Drain which signals infinite demand and executes the given callback for each received element. Depending on the arrival rate of the stream elements as well as the runtime of the callback up to parallelism invocations of the callback function will be run in parallel, i.e. in an overlapping fashion.

    CAUTION: The given callback might be called from several threads concurrently!

  31. def seq[T](limit: Int): Drain[T, Future[Seq[T]]]

    A Drain which signals demand of Integer.MAX_VALUE and buffers incoming elements in an immutable.Seq.

    A Drain which signals demand of Integer.MAX_VALUE and buffers incoming elements in an immutable.Seq. The given limit protects against an overflow beyond the expected maximum number of elements by failing the stream with a StreamLimitExceeded if more elements are received.

  32. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  33. def toPublisher[T](fanoutSupport: Boolean = false): Drain[T, Publisher[T]]

    A Drain which produces an associated Publisher.

    A Drain which produces an associated Publisher. Both are directly linked to each other and thereby allow for connecting *swave* with other Reactive Streams implementations.

    The Publisher produces all elements received by the Drain and the Drain forwards all request and cancel signals received by the Publisher.

    The returned Drain instance cannot run synchronously.

  34. def toString(): String
    Definition Classes
    AnyRef → Any
  35. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  36. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. object Capture extends Capture0

Inherited from AnyRef

Inherited from Any

Ungrouped