reactor.core.queue

Class CompletableLinkedQueue<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedTransferQueue<T>

reactor.core.queue.CompletableLinkedQueue<T>

All Implemented Interfaces:

Serializable, Iterable<T>, Collection<T>, BlockingQueue<T>, TransferQueue<T>, Queue<T>, CompletableQueue<T>

public final class CompletableLinkedQueue<T>
extends LinkedTransferQueue<T>
implements CompletableQueue<T>

A LinkedQueue that supports a terminal state.

Since:

2.0

Author:

Stephane Maldini

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompletableLinkedQueue()

Method Summary

Modifier and Type	Method and Description
void	complete() Mark this queue as complete
boolean	isComplete() Get the number of items persisted right now.

Methods inherited from class java.util.concurrent.LinkedTransferQueue

add, contains, drainTo, drainTo, getWaitingConsumerCount, hasWaitingConsumer, isEmpty, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, spliterator, take, transfer, tryTransfer, tryTransfer

Methods inherited from class java.util.AbstractQueue

addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Queue

add, element, offer, peek, poll, remove

Methods inherited from interface java.util.Collection

addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

CompletableLinkedQueue

public CompletableLinkedQueue()

Method Detail

complete

public void complete()

Description copied from interface: CompletableQueue

Mark this queue as complete

Specified by:

complete in interface CompletableQueue<T>

isComplete

public boolean isComplete()

Description copied from interface: CompletableQueue

Get the number of items persisted right now.

Specified by:

isComplete in interface CompletableQueue<T>

Returns:

true if current queue has been completed this#complete()