Package rx.internal.util.unsafe
-
Interface Summary Interface Description MessagePassingQueue<M> This is a tagging interface for the queues in this library which implement a subset of theQueue
interface sufficient for concurrent message passing.
Message passing queues offer happens before semantics to messages passed through, namely that writes made by the producer before offering the message are visible to the consuming thread after the message has been polled out of the queue.QueueProgressIndicators This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.