Uses of Class
rx.internal.operators.OnSubscribePublishMulticast.PublishProducer

Packages that use OnSubscribePublishMulticast.PublishProducer

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 OnSubscribePublishMulticast.PublishProducer in rx.internal.operators

Fields in rx.internal.operators declared as OnSubscribePublishMulticast.PublishProducer

Modifier and Type	Field	Description
(package private) static 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 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.PublishProducer

Modifier and Type	Method	Description
(package private) OnSubscribePublishMulticast.PublishProducer<T>[]	OnSubscribePublishMulticast.terminate()	Atomically swaps in the terminated state.

Methods in rx.internal.operators with parameters of type OnSubscribePublishMulticast.PublishProducer

Modifier and Type	Method	Description
(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.