io.reactivex.rxjava3.operators

public Interface SimplePlainQueue<T>

Known Direct Implementers

extends SimpleQueue<T>io.reactivex.rxjava3.operators.SpscArrayQueue, io.reactivex.rxjava3.operators.SpscLinkedArrayQueue, io.reactivex.rxjava3.internal.queue.MpscLinkedQueue

Type Parameters

<T>: the value type to offer and poll, not null

Imports

io.reactivex.rxjava3.annotations.*

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

Since: 3.1.1

Method Summary

Modifier and Type	Method and Description
public T	poll() Redeclares io.reactivex.rxjava3.operators.SimpleQueue.poll. Tries to dequeue a value (non-null) or returns null if the queue is empty.

Inherited from io.reactivex.rxjava3.operators.SimpleQueue:: clear isEmpty offer offer

Method Detail

poll back to summary

poll	back to summary
public T poll() Redeclares io.reactivex.rxjava3.operators.SimpleQueue.poll. Doc from io.reactivex.rxjava3.operators.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

public T poll()

Redeclares io.reactivex.rxjava3.operators.SimpleQueue.poll.

Doc from io.reactivex.rxjava3.operators.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