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.
-