Uses of Class
rx.internal.operators.OnSubscribePublishMulticast.PublishProducer
Packages that use OnSubscribePublishMulticast.PublishProducer
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of OnSubscribePublishMulticast.PublishProducer in rx.internal.operators
Fields in rx.internal.operators declared as OnSubscribePublishMulticast.PublishProducerModifier and TypeFieldDescription(package private) static final OnSubscribePublishMulticast.PublishProducer<?>[]
OnSubscribePublishMulticast.EMPTY
Represents an empty array of subscriber wrapper, helps avoid allocating an empty array all the time.(package private) OnSubscribePublishMulticast.PublishProducer<T>[]
OnSubscribePublishMulticast.subscribers
A copy-on-write array of currently subscribed child subscribers' wrapper structure.(package private) static final OnSubscribePublishMulticast.PublishProducer<?>[]
OnSubscribePublishMulticast.TERMINATED
Represents a final state for this class that prevents new subscribers from subscribing to it.Methods in rx.internal.operators that return OnSubscribePublishMulticast.PublishProducerModifier and TypeMethodDescription(package private) OnSubscribePublishMulticast.PublishProducer<T>[]
OnSubscribePublishMulticast.terminate()
Atomically swaps in the terminated state.Methods in rx.internal.operators with parameters of type OnSubscribePublishMulticast.PublishProducerModifier and TypeMethodDescription(package private) boolean
OnSubscribePublishMulticast.add
(OnSubscribePublishMulticast.PublishProducer<T> inner) Atomically adds the given wrapper of a child Subscriber to the subscribers array.(package private) void
OnSubscribePublishMulticast.remove
(OnSubscribePublishMulticast.PublishProducer<T> inner) Atomically removes the given wrapper, if present, from the subscribers array.