hu.akarnokd.rxjava2.util

Class BaseQueueDisposable<T>

java.lang.Object

hu.akarnokd.rxjava2.util.BaseQueueDisposable<T>

All Implemented Interfaces:

io.reactivex.disposables.Disposable, io.reactivex.internal.fuseable.QueueDisposable<T>, java.lang.Iterable<T>, java.util.Collection<T>, java.util.Queue<T>

Direct Known Subclasses:

DeferredScalarObserver

public abstract class BaseQueueDisposable<T>
extends java.lang.Object
implements io.reactivex.internal.fuseable.QueueDisposable<T>

Field Summary

Fields inherited from interface io.reactivex.internal.fuseable.QueueDisposable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor and Description
BaseQueueDisposable()

Method Summary

Modifier and Type	Method and Description
boolean	add(T e)
boolean	addAll(java.util.Collection<? extends T> c)
boolean	contains(java.lang.Object o)
boolean	containsAll(java.util.Collection<?> c)
T	element()
java.util.Iterator<T>	iterator()
boolean	offer(T e)
T	peek()
T	remove()
boolean	remove(java.lang.Object o)
boolean	removeAll(java.util.Collection<?> c)
boolean	retainAll(java.util.Collection<?> c)
int	size()
java.lang.Object[]	toArray()
<U> U[]	toArray(U[] a)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.reactivex.internal.fuseable.QueueDisposable

requestFusion

Methods inherited from interface java.util.Queue

poll

Methods inherited from interface java.util.Collection

clear, equals, hashCode, isEmpty, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface io.reactivex.disposables.Disposable

dispose, isDisposed

Constructor Detail

BaseQueueDisposable

public BaseQueueDisposable()

Method Detail

add

public final boolean add(T e)

Specified by:

add in interface java.util.Collection<T>

Specified by:

add in interface java.util.Queue<T>

addAll

public final boolean addAll(java.util.Collection<? extends T> c)

Specified by:

addAll in interface java.util.Collection<T>

contains

public final boolean contains(java.lang.Object o)

Specified by:

contains in interface java.util.Collection<T>

containsAll

public final boolean containsAll(java.util.Collection<?> c)

Specified by:

containsAll in interface java.util.Collection<T>

element

public final T element()

Specified by:

element in interface java.util.Queue<T>

iterator

public final java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

Specified by:

iterator in interface java.util.Collection<T>

offer

public final boolean offer(T e)

Specified by:

offer in interface java.util.Queue<T>

peek

public final T peek()

Specified by:

peek in interface java.util.Queue<T>

remove

public final T remove()

Specified by:

remove in interface java.util.Queue<T>

remove

public final boolean remove(java.lang.Object o)

Specified by:

remove in interface java.util.Collection<T>

removeAll

public final boolean removeAll(java.util.Collection<?> c)

Specified by:

removeAll in interface java.util.Collection<T>

retainAll

public boolean retainAll(java.util.Collection<?> c)

Specified by:

retainAll in interface java.util.Collection<T>

size

public final int size()

Specified by:

size in interface java.util.Collection<T>

toArray

public final java.lang.Object[] toArray()

Specified by:

toArray in interface java.util.Collection<T>

toArray

public final <U> U[] toArray(U[] a)

Specified by:

toArray in interface java.util.Collection<T>