com.github.davidmoten.rx.internal.operators

Interface QueueWithSubscription<T>

All Superinterfaces:

Collection<T>, Iterable<T>, Queue<T>, rx.Subscription

All Known Implementing Classes:

FileBasedSPSCQueueMemoryMapped

public interface QueueWithSubscription<T>
extends Queue<T>, rx.Subscription

Method Summary

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

Methods inherited from interface rx.Subscription

isUnsubscribed, unsubscribe