Extensions

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(iterator: Iterator[T])(implicit s: Scheduler): Future[Ack]

   

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

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

   

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

7. def getClass(): Class[_ <: AnyVal]

   

   Definition Classes

   AnyVal → Any

8. final def isInstanceOf[T0]: Boolean

   

   Definition Classes

   Any

9. val source: Observer[T]

   

10. def toReactive(bufferSize: Int)(implicit s: Scheduler): org.reactivestreams.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

11. def toReactive(implicit s: Scheduler): org.reactivestreams.Subscriber[T]

    

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

12. def toString(): String

    

    Definition Classes

    Any