Note that this conforms the Rx.NET behavior, but does not match former RxJava behavior, which operated as a regular buffer and mapped its lists to Observables.
| 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 int | |
| pack-priv final int |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public Subscriber |
| size | back to summary |
|---|---|
| pack-priv final int size | |
| skip | back to summary |
|---|---|
| pack-priv final int skip | |
| OperatorWindowWithSize | back to summary |
|---|---|
| public OperatorWindowWithSize(int size, int skip) | |
| call | back to summary |
|---|---|
| public Subscriber Implements rx.
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Subscriber | |
| pack-priv final Subscription | |
| pack-priv int | |
| pack-priv final int | |
| pack-priv Subject | |
| pack-priv final AtomicInteger |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| pack-priv Producer | |
| public void | onCompleted()
Implements rx. Observable has finished sending push-based notifications.
|
| public void | onError(Throwable
the exception encountered by the Observable e)Implements rx. Observable has experienced an error condition.
|
| public void | onNext(T
the item emitted by the Observable t)Implements rx. |
| actual | back to summary |
|---|---|
| pack-priv final Subscriber<? super Observable<T>> actual | |
| cancel | back to summary |
|---|---|
| pack-priv final Subscription cancel | |
| index | back to summary |
|---|---|
| pack-priv int index | |
| size | back to summary |
|---|---|
| pack-priv final int size | |
| window | back to summary |
|---|---|
| pack-priv Subject<T, T> window | |
| wip | back to summary |
|---|---|
| pack-priv final AtomicInteger wip | |
| WindowExact | back to summary |
|---|---|
| public WindowExact(Subscriber<? super Observable<T>> actual, int size) | |
| call | back to summary |
|---|---|
| public void call() Implements rx.
| |
| createProducer | back to summary |
|---|---|
| pack-priv Producer createProducer() | |
| onCompleted | back to summary |
|---|---|
| public void onCompleted() Implements rx. Doc from rx. Notifies the Observer that the
The
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable e) Implements rx. Doc from rx. Notifies the Observer that the
If the | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements rx. Doc from rx. Provides the Observer with a new item to observe.
The
The
| |
| Modifier and Type | Class and Description |
|---|---|
| pack-priv class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Subscriber | |
| pack-priv final Subscription | |
| pack-priv volatile boolean | |
| pack-priv final AtomicInteger | |
| pack-priv Throwable | |
| pack-priv int | |
| pack-priv int | |
| pack-priv final Queue | |
| pack-priv final AtomicLong | |
| pack-priv final int | |
| pack-priv final int | |
| pack-priv final ArrayDeque | |
| pack-priv final AtomicInteger |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| pack-priv boolean | checkTerminated(boolean d, boolean empty, Subscriber<? super Subject<T, T>> a, Queue<Subject<T, T>> q)
|
| pack-priv Producer | |
| pack-priv void | |
| public void | onCompleted()
Implements rx. Observable has finished sending push-based notifications.
|
| public void | onError(Throwable
the exception encountered by the Observable e)Implements rx. Observable has experienced an error condition.
|
| public void | onNext(T
the item emitted by the Observable t)Implements rx. |
| actual | back to summary |
|---|---|
| pack-priv final Subscriber<? super Observable<T>> actual | |
| cancel | back to summary |
|---|---|
| pack-priv final Subscription cancel | |
| done | back to summary |
|---|---|
| pack-priv volatile boolean done | |
| drainWip | back to summary |
|---|---|
| pack-priv final AtomicInteger drainWip | |
| error | back to summary |
|---|---|
| pack-priv Throwable error | |
| index | back to summary |
|---|---|
| pack-priv int index | |
| produced | back to summary |
|---|---|
| pack-priv int produced | |
| queue | back to summary |
|---|---|
| pack-priv final Queue<Subject<T, T>> queue | |
| requested | back to summary |
|---|---|
| pack-priv final AtomicLong requested Hides rx. | |
| size | back to summary |
|---|---|
| pack-priv final int size | |
| skip | back to summary |
|---|---|
| pack-priv final int skip | |
| windows | back to summary |
|---|---|
| pack-priv final ArrayDeque<Subject<T, T>> windows | |
| wip | back to summary |
|---|---|
| pack-priv final AtomicInteger wip | |
| WindowOverlap | back to summary |
|---|---|
| public WindowOverlap(Subscriber<? super Observable<T>> actual, int size, int skip) | |
| call | back to summary |
|---|---|
| public void call() Implements rx.
| |
| checkTerminated | back to summary |
|---|---|
| pack-priv boolean checkTerminated(boolean d, boolean empty, Subscriber<? super Subject<T, T>> a, Queue<Subject<T, T>> q) | |
| createProducer | back to summary |
|---|---|
| pack-priv Producer createProducer() | |
| drain | back to summary |
|---|---|
| pack-priv void drain() | |
| onCompleted | back to summary |
|---|---|
| public void onCompleted() Implements rx. Doc from rx. Notifies the Observer that the
The
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable e) Implements rx. Doc from rx. Notifies the Observer that the
If the | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements rx. Doc from rx. Provides the Observer with a new item to observe.
The
The
| |
| Modifier and Type | Field and Description |
|---|---|
| private static final long |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | request(long
the maximum number of items you want this Producer to produce, or n)Long.MAX_VALUE if you
want the Producer to produce items at its own paceImplements rx. |
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID Hides java. | |
| WindowOverlapProducer | back to summary |
|---|---|
| pack-priv WindowOverlapProducer() | |
| request | back to summary |
|---|---|
| public void request(long n) Implements rx. Doc from rx. Request a certain maximum number of items from this Producer. This is a way of requesting backpressure.
To disable backpressure, pass
Requests are additive but if a sequence of requests totals more than request(100); request(Long.MAX_VALUE-1);
| |
| Modifier and Type | Class and Description |
|---|---|
| pack-priv class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Subscriber | |
| pack-priv final Subscription | |
| pack-priv int | |
| pack-priv final int | |
| pack-priv final int | |
| pack-priv Subject | |
| pack-priv final AtomicInteger |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| pack-priv Producer | |
| public void | onCompleted()
Implements rx. Observable has finished sending push-based notifications.
|
| public void | onError(Throwable
the exception encountered by the Observable e)Implements rx. Observable has experienced an error condition.
|
| public void | onNext(T
the item emitted by the Observable t)Implements rx. |
| actual | back to summary |
|---|---|
| pack-priv final Subscriber<? super Observable<T>> actual | |
| cancel | back to summary |
|---|---|
| pack-priv final Subscription cancel | |
| index | back to summary |
|---|---|
| pack-priv int index | |
| size | back to summary |
|---|---|
| pack-priv final int size | |
| skip | back to summary |
|---|---|
| pack-priv final int skip | |
| window | back to summary |
|---|---|
| pack-priv Subject<T, T> window | |
| wip | back to summary |
|---|---|
| pack-priv final AtomicInteger wip | |
| WindowSkip | back to summary |
|---|---|
| public WindowSkip(Subscriber<? super Observable<T>> actual, int size, int skip) | |
| call | back to summary |
|---|---|
| public void call() Implements rx.
| |
| createProducer | back to summary |
|---|---|
| pack-priv Producer createProducer() | |
| onCompleted | back to summary |
|---|---|
| public void onCompleted() Implements rx. Doc from rx. Notifies the Observer that the
The
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable e) Implements rx. Doc from rx. Notifies the Observer that the
If the | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements rx. Doc from rx. Provides the Observer with a new item to observe.
The
The
| |
| Modifier and Type | Field and Description |
|---|---|
| private static final long |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | request(long
the maximum number of items you want this Producer to produce, or n)Long.MAX_VALUE if you
want the Producer to produce items at its own paceImplements rx. |
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID Hides java. | |
| WindowSkipProducer | back to summary |
|---|---|
| pack-priv WindowSkipProducer() | |
| request | back to summary |
|---|---|
| public void request(long n) Implements rx. Doc from rx. Request a certain maximum number of items from this Producer. This is a way of requesting backpressure.
To disable backpressure, pass
Requests are additive but if a sequence of requests totals more than request(100); request(Long.MAX_VALUE-1);
| |