Uses of Class
rx.internal.operators.OperatorPublish.InnerProducer

Packages that use OperatorPublish.InnerProducer

Package	Description
rx.internal.operators	Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.

Uses of OperatorPublish.InnerProducer in rx.internal.operators

Fields in rx.internal.operators declared as OperatorPublish.InnerProducer

Modifier and Type	Field	Description
(package private) static final OperatorPublish.InnerProducer[]	OperatorPublish.PublishSubscriber.EMPTY	Indicates an empty array of inner producers.
(package private) static final OperatorPublish.InnerProducer[]	OperatorPublish.PublishSubscriber.TERMINATED	Indicates a terminated PublishSubscriber.

Methods in rx.internal.operators with parameters of type OperatorPublish.InnerProducer

Modifier and Type	Method	Description
(package private) boolean	OperatorPublish.PublishSubscriber.add(OperatorPublish.InnerProducer<T> producer)	Atomically try adding a new InnerProducer to this Subscriber or return false if this Subscriber was terminated.
(package private) void	OperatorPublish.PublishSubscriber.remove(OperatorPublish.InnerProducer<T> producer)	Atomically removes the given producer from the producers array.