Top Description Methods
io.reactivex.internal.fuseable

public Interface SimplePlainQueue<T>

extends SimpleQueue<T>
Known Direct Implementers
io.reactivex.internal.queue.MpscLinkedQueue, io.reactivex.internal.queue.SpscArrayQueue, io.reactivex.internal.queue.SpscLinkedArrayQueue
Type Parameters
<T>
the value type to offer and poll, not null
Imports
io.reactivex.annotations.Nullable

Override of the SimpleQueue interface with no throws Exception on poll().

Method Summary

Modifier and TypeMethod and Description
public T
poll()

Redeclares io.reactivex.internal.fuseable.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.
Inherited from io.reactivex.internal.fuseable.SimpleQueue:
clearisEmptyofferoffer

Method Detail

pollback to summary
public T poll()

Redeclares io.reactivex.internal.fuseable.SimpleQueue.poll.

Doc from io.reactivex.internal.fuseable.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.

If the producer uses 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.

Returns:T

the item or null to indicate an empty queue

Annotations
@Nullable
@Override