| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class | |
| pack-priv static class | |
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Callable | |
| pack-priv final int | |
| pack-priv final boolean | |
| pack-priv final Scheduler | |
| pack-priv final long | |
| pack-priv final long | |
| pack-priv final TimeUnit |
| Access | Constructor and Description |
|---|---|
| public | ObservableBufferTimed(ObservableSource<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Callable<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize)
|
| Modifier and Type | Method and Description |
|---|---|
| protected void | subscribeActual(Observer<? super U>
the incoming Observer, never null t)Implements abstract io. Observers.
|
| bufferSupplier | back to summary |
|---|---|
| pack-priv final Callable<U> bufferSupplier | |
| maxSize | back to summary |
|---|---|
| pack-priv final int maxSize | |
| restartTimerOnMaxSize | back to summary |
|---|---|
| pack-priv final boolean restartTimerOnMaxSize | |
| scheduler | back to summary |
|---|---|
| pack-priv final Scheduler scheduler | |
| timeskip | back to summary |
|---|---|
| pack-priv final long timeskip | |
| timespan | back to summary |
|---|---|
| pack-priv final long timespan | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| ObservableBufferTimed | back to summary |
|---|---|
| public ObservableBufferTimed(ObservableSource<T> source, long timespan, long timeskip, TimeUnit unit, Scheduler scheduler, Callable<U> bufferSupplier, int maxSize, boolean restartTimerOnMaxSize) | |
| subscribeActual | back to summary |
|---|---|
| protected void subscribeActual(Observer<? super U> t) Implements abstract io. Doc from io. Operator implementations (both source and intermediate) should implement this method that
performs the necessary business logic and handles the incoming There is no need to call any of the plugin hooks on the current | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv U | |
| pack-priv final Callable | |
| pack-priv long | |
| pack-priv final int | |
| pack-priv long | |
| pack-priv final boolean | |
| pack-priv Disposable | |
| pack-priv final long | |
| pack-priv final TimeUnit | |
| pack-priv Disposable | |
| pack-priv final Scheduler. |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | accept(Observer<? super U>
the subscriber to deliver values to a, U the value to deliver v)Overrides io. Implements io. |
| public void | dispose()
Implements io. |
| public boolean | isDisposed()
Implements io. |
| public void | onComplete()
Implements io. Observable has finished sending push-based notifications.
|
| public void | onError(Throwable
the exception encountered by the Observable t)Implements io. Observable has experienced an error condition.
|
| public void | onNext(T
the item emitted by the Observable t)Implements io. |
| public void | onSubscribe(Disposable
the Disposable instance whose d)Disposable#dispose() can
be called anytime to cancel the connectionImplements io. onNext(Object)) and asynchronous manner.
|
| public void |
| buffer | back to summary |
|---|---|
| pack-priv U buffer | |
| bufferSupplier | back to summary |
|---|---|
| pack-priv final Callable<U> bufferSupplier | |
| consumerIndex | back to summary |
|---|---|
| pack-priv long consumerIndex | |
| maxSize | back to summary |
|---|---|
| pack-priv final int maxSize | |
| producerIndex | back to summary |
|---|---|
| pack-priv long producerIndex | |
| restartTimerOnMaxSize | back to summary |
|---|---|
| pack-priv final boolean restartTimerOnMaxSize | |
| timer | back to summary |
|---|---|
| pack-priv Disposable timer | |
| timespan | back to summary |
|---|---|
| pack-priv final long timespan | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| upstream | back to summary |
|---|---|
| pack-priv Disposable upstream | |
| w | back to summary |
|---|---|
| pack-priv final Scheduler. | |
| BufferExactBoundedObserver | back to summary |
|---|---|
| pack-priv BufferExactBoundedObserver(Observer<? super U> actual, Callable<U> bufferSupplier, long timespan, TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler. | |
| accept | back to summary |
|---|---|
| public void accept(Observer<? super U> a, U v) Overrides io. Implements io. Doc from io. Accept the value and return true if forwarded. | |
| dispose | back to summary |
|---|---|
| public void dispose() Implements io. Doc from io. Dispose the resource, the operation should be idempotent.
| |
| isDisposed | back to summary |
|---|---|
| public boolean isDisposed() Implements io. Doc from io. Returns true if this resource has been disposed.
| |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements io. Doc from io. Notifies the Observer that the
The
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Implements io. Doc from io. Notifies the Observer that the
If the | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements io. Doc from io. Provides the Observer with a new item to observe.
The
The
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Disposable d) Implements io. Doc from io. Provides the Observer with the means of cancelling (disposing) the
connection (channel) with the Observable in both
synchronous (from within
| |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv U | |
| pack-priv final Callable | |
| pack-priv final Scheduler | |
| pack-priv final AtomicReference | |
| pack-priv final long | |
| pack-priv final TimeUnit | |
| pack-priv Disposable |
| Access | Constructor and Description |
|---|---|
| pack-priv | BufferExactUnboundedObserver(Observer<? super U> actual, Callable<U> bufferSupplier, long timespan, TimeUnit unit, Scheduler scheduler)
|
| Modifier and Type | Method and Description |
|---|---|
| public void | accept(Observer<? super U>
the subscriber to deliver values to a, U the value to deliver v)Overrides io. Implements io. |
| public void | dispose()
Implements io. |
| public boolean | isDisposed()
Implements io. |
| public void | onComplete()
Implements io. Observable has finished sending push-based notifications.
|
| public void | onError(Throwable
the exception encountered by the Observable t)Implements io. Observable has experienced an error condition.
|
| public void | onNext(T
the item emitted by the Observable t)Implements io. |
| public void | onSubscribe(Disposable
the Disposable instance whose d)Disposable#dispose() can
be called anytime to cancel the connectionImplements io. onNext(Object)) and asynchronous manner.
|
| public void |
| buffer | back to summary |
|---|---|
| pack-priv U buffer | |
| bufferSupplier | back to summary |
|---|---|
| pack-priv final Callable<U> bufferSupplier | |
| scheduler | back to summary |
|---|---|
| pack-priv final Scheduler scheduler | |
| timer | back to summary |
|---|---|
| pack-priv final AtomicReference<Disposable> timer | |
| timespan | back to summary |
|---|---|
| pack-priv final long timespan | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| upstream | back to summary |
|---|---|
| pack-priv Disposable upstream | |
| BufferExactUnboundedObserver | back to summary |
|---|---|
| pack-priv BufferExactUnboundedObserver(Observer<? super U> actual, Callable<U> bufferSupplier, long timespan, TimeUnit unit, Scheduler scheduler) | |
| accept | back to summary |
|---|---|
| public void accept(Observer<? super U> a, U v) Overrides io. Implements io. Doc from io. Accept the value and return true if forwarded. | |
| dispose | back to summary |
|---|---|
| public void dispose() Implements io. Doc from io. Dispose the resource, the operation should be idempotent.
| |
| isDisposed | back to summary |
|---|---|
| public boolean isDisposed() Implements io. Doc from io. Returns true if this resource has been disposed.
| |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements io. Doc from io. Notifies the Observer that the
The
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Implements io. Doc from io. Notifies the Observer that the
If the | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements io. Doc from io. Provides the Observer with a new item to observe.
The
The
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Disposable d) Implements io. Doc from io. Provides the Observer with the means of cancelling (disposing) the
connection (channel) with the Observable in both
synchronous (from within
| |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |
| Modifier and Type | Class and Description |
|---|---|
| pack-priv class | |
| pack-priv class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final List | |
| pack-priv final Callable | |
| pack-priv final long | |
| pack-priv final long | |
| pack-priv final TimeUnit | |
| pack-priv Disposable | |
| pack-priv final Scheduler. |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | accept(Observer<? super U>
the subscriber to deliver values to a, U the value to deliver v)Overrides io. Implements io. |
| pack-priv void | |
| public void | dispose()
Implements io. |
| public boolean | isDisposed()
Implements io. |
| public void | onComplete()
Implements io. Observable has finished sending push-based notifications.
|
| public void | onError(Throwable
the exception encountered by the Observable t)Implements io. Observable has experienced an error condition.
|
| public void | onNext(T
the item emitted by the Observable t)Implements io. |
| public void | onSubscribe(Disposable
the Disposable instance whose d)Disposable#dispose() can
be called anytime to cancel the connectionImplements io. onNext(Object)) and asynchronous manner.
|
| public void |
| buffers | back to summary |
|---|---|
| pack-priv final List<U> buffers | |
| bufferSupplier | back to summary |
|---|---|
| pack-priv final Callable<U> bufferSupplier | |
| timeskip | back to summary |
|---|---|
| pack-priv final long timeskip | |
| timespan | back to summary |
|---|---|
| pack-priv final long timespan | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| upstream | back to summary |
|---|---|
| pack-priv Disposable upstream | |
| w | back to summary |
|---|---|
| pack-priv final Scheduler. | |
| BufferSkipBoundedObserver | back to summary |
|---|---|
| pack-priv BufferSkipBoundedObserver(Observer<? super U> actual, Callable<U> bufferSupplier, long timespan, long timeskip, TimeUnit unit, Scheduler. | |
| accept | back to summary |
|---|---|
| public void accept(Observer<? super U> a, U v) Overrides io. Implements io. Doc from io. Accept the value and return true if forwarded. | |
| clear | back to summary |
|---|---|
| pack-priv void clear() | |
| dispose | back to summary |
|---|---|
| public void dispose() Implements io. Doc from io. Dispose the resource, the operation should be idempotent.
| |
| isDisposed | back to summary |
|---|---|
| public boolean isDisposed() Implements io. Doc from io. Returns true if this resource has been disposed.
| |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements io. Doc from io. Notifies the Observer that the
The
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Implements io. Doc from io. Notifies the Observer that the
If the | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements io. Doc from io. Provides the Observer with a new item to observe.
The
The
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Disposable d) Implements io. Doc from io. Provides the Observer with the means of cancelling (disposing) the
connection (channel) with the Observable in both
synchronous (from within
| |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final U |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void |
| b | back to summary |
|---|---|
| private final U b | |
| RemoveFromBuffer | back to summary |
|---|---|
| pack-priv RemoveFromBuffer(U b) | |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final U |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void |
| buffer | back to summary |
|---|---|
| private final U buffer | |
| RemoveFromBufferEmit | back to summary |
|---|---|
| pack-priv RemoveFromBufferEmit(U buffer) | |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |