Class ObservableBufferTimed.BufferSkipBoundedObserver<T,U extends Collection<? super T>>
java.lang.Object
io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberPad0
io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberWip
io.reactivex.rxjava3.internal.observers.QueueDrainSubscriberPad2
io.reactivex.rxjava3.internal.observers.QueueDrainObserver<T,U,U>
io.reactivex.rxjava3.internal.operators.observable.ObservableBufferTimed.BufferSkipBoundedObserver<T,U>
- All Implemented Interfaces:
Observer<T>
,Disposable
,ObservableQueueDrain<U,
,U> Runnable
- Enclosing class:
ObservableBufferTimed<T,
U extends Collection<? super T>>
static final class ObservableBufferTimed.BufferSkipBoundedObserver<T,U extends Collection<? super T>>
extends QueueDrainObserver<T,U,U>
implements Runnable, Disposable
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) final class
(package private) final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final long
(package private) final long
(package private) final TimeUnit
(package private) Disposable
(package private) final Scheduler.Worker
Fields inherited from class io.reactivex.rxjava3.internal.observers.QueueDrainObserver
cancelled, done, downstream, error, queue
-
Constructor Summary
ConstructorsConstructorDescriptionBufferSkipBoundedObserver
(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker w) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Accept the value and return true if forwarded.(package private) void
clear()
void
dispose()
Dispose the resource, the operation should be idempotent.boolean
Returns true if this resource has been disposed.void
Notifies theObserver
that theObservable
has finished sending push-based notifications.void
Notifies theObserver
that theObservable
has experienced an error condition.void
Provides theObserver
with a new item to observe.void
Provides theObserver
with the means of cancelling (disposing) the connection (channel) with theObservable
in both synchronous (from withinObserver.onNext(Object)
) and asynchronous manner.void
run()
Methods inherited from class io.reactivex.rxjava3.internal.observers.QueueDrainObserver
cancelled, done, enter, error, fastPathEmit, fastPathOrderedEmit, leave
-
Field Details
-
bufferSupplier
-
timespan
final long timespan -
timeskip
final long timeskip -
unit
-
w
-
buffers
-
upstream
Disposable upstream
-
-
Constructor Details
-
BufferSkipBoundedObserver
-
-
Method Details
-
onSubscribe
Description copied from interface:Observer
Provides theObserver
with the means of cancelling (disposing) the connection (channel) with theObservable
in both synchronous (from withinObserver.onNext(Object)
) and asynchronous manner.- Specified by:
onSubscribe
in interfaceObserver<T>
- Parameters:
d
- theDisposable
instance whoseDisposable.dispose()
can be called anytime to cancel the connection
-
onNext
Description copied from interface:Observer
Provides theObserver
with a new item to observe.The
Observable
may call this method 0 or more times.The
Observable
will not call this method again after it calls eitherObserver.onComplete()
orObserver.onError(java.lang.Throwable)
. -
onError
Description copied from interface:Observer
Notifies theObserver
that theObservable
has experienced an error condition.If the
Observable
calls this method, it will not thereafter callObserver.onNext(T)
orObserver.onComplete()
. -
onComplete
public void onComplete()Description copied from interface:Observer
Notifies theObserver
that theObservable
has finished sending push-based notifications.The
Observable
will not call this method if it callsObserver.onError(java.lang.Throwable)
.- Specified by:
onComplete
in interfaceObserver<T>
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
clear
void clear() -
run
public void run() -
accept
Description copied from interface:ObservableQueueDrain
Accept the value and return true if forwarded.- Specified by:
accept
in interfaceObservableQueueDrain<T,
U extends Collection<? super T>> - Overrides:
accept
in classQueueDrainObserver<T,
U extends Collection<? super T>, U extends Collection<? super T>> - Parameters:
a
- the subscriber to deliver values tov
- the value to deliver
-