Uses of Class
rx.internal.operators.OperatorPublish.InnerProducer
Packages that use OperatorPublish.InnerProducer
Package
Description
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.InnerProducerModifier and TypeFieldDescription(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.InnerProducerModifier and TypeMethodDescription(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.