Extension methods for Observer.
Feeds the given Observer instance with elements from the given iterator,
respecting the contract and returning a Future[Ack]
with the last
acknowledgement given after the last emitted element.
Feeds the given Observer instance with elements from the given iterable,
respecting the contract and returning a Future[Ack]
with the last
acknowledgement given after the last emitted element.
Given an org.reactivestreams.Subscriber
as defined by the
Reactive Streams specification,
it builds an Observer instance compliant with the
Monifu Rx implementation.
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.
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
Transforms the source Observer into a org.reactivestreams.Subscriber
instance as defined by the Reactive Streams
specification.