Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.internal.observers | |
rx.internal.operators |
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
|
rx.internal.producers | |
rx.internal.util | |
rx.observers |
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
|
Modifier and Type | Method and Description |
---|---|
void |
Subscriber.setProducer(Producer p)
If other subscriber is set (by calling constructor
Subscriber.Subscriber(Subscriber) or
Subscriber.Subscriber(Subscriber, boolean) ) then this method calls
setProducer on the other subscriber. |
Modifier and Type | Method and Description |
---|---|
void |
AssertableSubscriberObservable.setProducer(Producer p) |
Modifier and Type | Class and Description |
---|---|
static class |
OperatorGroupBy.GroupByProducer
Deprecated.
|
static class |
OperatorGroupByEvicting.GroupByProducer |
Modifier and Type | Method and Description |
---|---|
void |
OperatorGroupByEvicting.GroupBySubscriber.setProducer(Producer s) |
void |
OperatorGroupBy.GroupBySubscriber.setProducer(Producer s) |
void |
DeferredScalarSubscriber.setProducer(Producer p) |
Modifier and Type | Class and Description |
---|---|
class |
ProducerArbiter
Producer that allows changing an underlying producer atomically and correctly resume with the accumulated
requests.
|
class |
ProducerObserverArbiter<T>
Producer that serializes any event emission with requesting and producer changes.
|
class |
QueuedProducer<T>
Producer that holds an unbounded (or custom) queue, handles terminal events,
enqueues values and relays them to a child subscriber on request.
|
class |
QueuedValueProducer<T>
Producer that holds an unbounded (or custom) queue to enqueue values and relays them
to a child subscriber on request.
|
class |
SingleDelayedProducer<T>
Producer that emits a single value and completes the child subscriber once that
single value is set on it and the child requested items (maybe both asynchronously).
|
class |
SingleProducer<T>
A producer which emits a single value and completes the child on the first positive request.
|
Modifier and Type | Method and Description |
---|---|
void |
ProducerObserverArbiter.setProducer(Producer p) |
void |
ProducerArbiter.setProducer(Producer newProducer) |
Modifier and Type | Class and Description |
---|---|
class |
BackpressureDrainManager
Manages the producer-backpressure-consumer interplay by
matching up available elements with requested elements and/or
terminal events.
|
Modifier and Type | Method and Description |
---|---|
void |
AssertableSubscriber.setProducer(Producer p)
Allows manually calling the
setProducer method of the underlying Subscriber. |
Copyright © 2018. All rights reserved.