Package io.reactivex.rxjava3.operators
Interface SimplePlainQueue<T>
- Type Parameters:
T
- the value type to offer and poll, not null
- All Superinterfaces:
SimpleQueue<T>
- All Known Implementing Classes:
MpscLinkedQueue
,SpscArrayQueue
,SpscLinkedArrayQueue
- Since:
- 3.1.1
-
Method Summary
Methods inherited from interface io.reactivex.rxjava3.operators.SimpleQueue
clear, isEmpty, offer, offer
-
Method Details
-
poll
Description copied from interface:SimpleQueue
Tries to dequeue a value (non-null) or returns null if the queue is empty.If the producer uses
SimpleQueue.offer(Object, Object)
and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.- Specified by:
poll
in interfaceSimpleQueue<T>
- Returns:
- the item or null to indicate an empty queue
-