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 OperatorPublish.InnerProducer[]
OperatorPublish.PublishSubscriber. EMPTY
Indicates an empty array of inner producers.(package private) static 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.
-