Packages

implicit final class Extensions[T] extends AnyVal

Extension methods for Observer.

Source
Observer.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Extensions
  2. AnyVal
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Extensions(target: Observer[T])

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    Any
  2. final def ##(): Int
    Definition Classes
    Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def feed(subscription: BooleanCancelable, iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    subscription

    is a BooleanCancelable that will be queried for its cancellation status, but only on asynchronous boundaries, and when it is seen as being isCanceled, streaming is stopped

    iterator

    is the collection of items to push downstream

  6. def feed(iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    iterator

    is the collection of items to push downstream

  7. def feed(subscription: BooleanCancelable, iterable: Iterable[T])(implicit s: Scheduler): Future[Ack]

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    subscription

    is a BooleanCancelable that will be queried for its cancellation status, but only on asynchronous boundaries, and when it is seen as being isCanceled, streaming is stopped

    iterable

    is the collection of items to push downstream

  8. def feed(iterable: Iterable[T])(implicit s: Scheduler): Future[Ack]

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    iterable

    is the collection of items to push downstream

  9. def getClass(): Class[_ <: AnyVal]
    Definition Classes
    AnyVal → Any
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. def onNextAll(xs: TraversableOnce[T])(implicit s: Scheduler): Future[Ack]

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    Feeds the Observer instance with elements from the given collection, respecting the contract and returning a Future[Ack] with the last acknowledgement given after the last emitted element.

    xs

    the traversable object containing the elements to feed into our observer.

  12. val target: Observer[T]
  13. def toReactive(bufferSize: Int)(implicit s: Scheduler): Subscriber[T]

    Transforms the source Observer into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.

    Transforms the source Observer into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.

    bufferSize

    a strictly positive number, representing the size of the buffer used and the number of elements requested on each cycle when communicating demand, compliant with the reactive streams specification

  14. def toReactive(implicit s: Scheduler): Subscriber[T]

    Transforms the source Observer into a org.reactivestreams.Subscriber instance as defined by the Reactive Streams specification.

  15. def toString(): String
    Definition Classes
    Any

Inherited from AnyVal

Inherited from Any

Ungrouped