Class ObservableBuffer.BufferSkipObserver<T,U extends java.util.Collection<? super T>>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicBoolean
-
- io.reactivex.rxjava3.internal.operators.observable.ObservableBuffer.BufferSkipObserver<T,U>
-
- All Implemented Interfaces:
Observer<T>,Disposable,java.io.Serializable
- Enclosing class:
- ObservableBuffer<T,U extends java.util.Collection<? super T>>
static final class ObservableBuffer.BufferSkipObserver<T,U extends java.util.Collection<? super T>> extends java.util.concurrent.atomic.AtomicBoolean implements Observer<T>, Disposable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.util.ArrayDeque<U>buffers(package private) Supplier<U>bufferSupplier(package private) intcount(package private) Observer<? super U>downstream(package private) longindexprivate static longserialVersionUID(package private) intskip(package private) Disposableupstream
-
Constructor Summary
Constructors Constructor Description BufferSkipObserver(Observer<? super U> actual, int count, int skip, Supplier<U> bufferSupplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddispose()Dispose the resource, the operation should be idempotent.booleanisDisposed()Returns true if this resource has been disposed.voidonComplete()Notifies theObserverthat theObservablehas finished sending push-based notifications.voidonError(java.lang.Throwable t)Notifies theObserverthat theObservablehas experienced an error condition.voidonNext(T t)Provides theObserverwith a new item to observe.voidonSubscribe(Disposable d)Provides theObserverwith the means of cancelling (disposing) the connection (channel) with theObservablein both synchronous (from withinObserver.onNext(Object)) and asynchronous manner.-
Methods inherited from class java.util.concurrent.atomic.AtomicBoolean
compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndSet, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
count
final int count
-
skip
final int skip
-
upstream
Disposable upstream
-
index
long index
-
-
Method Detail
-
onSubscribe
public void onSubscribe(Disposable d)
Description copied from interface:ObserverProvides theObserverwith the means of cancelling (disposing) the connection (channel) with theObservablein both synchronous (from withinObserver.onNext(Object)) and asynchronous manner.- Specified by:
onSubscribein interfaceObserver<T>- Parameters:
d- theDisposableinstance whoseDisposable.dispose()can be called anytime to cancel the connection
-
dispose
public void dispose()
Description copied from interface:DisposableDispose the resource, the operation should be idempotent.- Specified by:
disposein interfaceDisposable
-
isDisposed
public boolean isDisposed()
Description copied from interface:DisposableReturns true if this resource has been disposed.- Specified by:
isDisposedin interfaceDisposable- Returns:
- true if this resource has been disposed
-
onNext
public void onNext(T t)
Description copied from interface:ObserverProvides theObserverwith a new item to observe.The
Observablemay call this method 0 or more times.The
Observablewill not call this method again after it calls eitherObserver.onComplete()orObserver.onError(java.lang.Throwable).
-
onError
public void onError(java.lang.Throwable t)
Description copied from interface:ObserverNotifies theObserverthat theObservablehas experienced an error condition.If the
Observablecalls this method, it will not thereafter callObserver.onNext(T)orObserver.onComplete().
-
onComplete
public void onComplete()
Description copied from interface:ObserverNotifies theObserverthat theObservablehas finished sending push-based notifications.The
Observablewill not call this method if it callsObserver.onError(java.lang.Throwable).- Specified by:
onCompletein interfaceObserver<T>
-
-