implicit final class Extensions[A] extends AnyVal
Extension methods for Subscriber.
- Alphabetic
- By Inheritance
- Extensions
- AnyVal
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new Extensions(target: Subscriber[A])
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
##(): Int
- Definition Classes
- Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
contramap[B](f: (B) ⇒ A): Subscriber[B]
Given a contravariant mapping function, transform the source Subscriber by transforming the input.
-
def
feed(subscription: BooleanCancelable, iterator: Iterator[A]): Future[Ack]
Feeds the source Subscriber 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 source Subscriber 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 iterator of items to push downstream
-
def
feed(iterator: Iterator[A]): Future[Ack]
Feeds the source Subscriber 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 source Subscriber 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 iterator of items to push downstream
-
def
feed(subscription: BooleanCancelable, iterable: Iterable[A]): Future[Ack]
Feeds the source Subscriber 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 source Subscriber 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
-
def
feed(iterable: Iterable[A]): Future[Ack]
Feeds the source Subscriber 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 source Subscriber 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
-
def
getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
onNextAll(xs: Iterable[A]): Future[Ack]
Feeds the source Subscriber 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 source Subscriber 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 subscriber
- val target: Subscriber[A]
-
def
toReactive(requestCount: Int): org.reactivestreams.Subscriber[A]
Transforms the source Subscriber into a
org.reactivestreams.Subscriber
instance as defined by the Reactive Streams specification.Transforms the source Subscriber into a
org.reactivestreams.Subscriber
instance as defined by the Reactive Streams specification.- requestCount
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
-
def
toReactive: org.reactivestreams.Subscriber[A]
Transforms the source Subscriber into a
org.reactivestreams.Subscriber
instance as defined by the Reactive Streams specification. -
def
toString(): String
- Definition Classes
- Any