Termination of either Publishers will result in termination for the Subscriber as well.
Both Publishers will run in unbounded mode because the backpressure would interfere with the sampling precision.
| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class | |
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Publisher |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public int | getPrefetch()
Overrides reactor. Flux
|
| public Object | scanUnsafe(Scannable.
a keyAttr to resolve for the component.Overrides reactor. Implements reactor. |
| public CoreSubscriber | subscribeOrReturn(CoreSubscriber<? super T> actual)
Implements abstract reactor. Implements reactor. CoreSubscriber, or force
subscription encapsulation by returning null.
|
| other | back to summary |
|---|---|
| pack-priv final Publisher<U> other | |
| FluxSample | back to summary |
|---|---|
| pack-priv FluxSample(Flux<? extends T> source, Publisher<U> other) | |
| getPrefetch | back to summary |
|---|---|
| public int getPrefetch() Overrides reactor. Doc from reactor. The prefetch configuration of the | |
| scanUnsafe | back to summary |
|---|---|
| public Object scanUnsafe(Scannable. Overrides reactor. Implements reactor. Doc from reactor. This method is used internally by components to define their key-value mappings
in a single place. Although it is ignoring the generic type of the
For public consumption of attributes, prefer using | |
| subscribeOrReturn | back to summary |
|---|---|
| public CoreSubscriber Implements abstract reactor. Implements reactor. Doc from reactor. Allow delegation of the subscription by returning a
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final CoreSubscriber | |
| pack-priv final Context | |
| pack-priv volatile Subscription | |
| pack-priv static final AtomicReferenceFieldUpdater | |
| pack-priv volatile Subscription | |
| pack-priv static final AtomicReferenceFieldUpdater | |
| pack-priv volatile long | |
| pack-priv static final AtomicLongFieldUpdater | |
| pack-priv volatile T | |
| pack-priv static final AtomicReferenceFieldUpdater |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public final CoreSubscriber | |
| public void | cancel()
Implements org. Publisher to stop sending data and clean up resources.
|
| pack-priv void | |
| pack-priv void | |
| pack-priv void | |
| pack-priv T | |
| public Stream | inners()
Overrides default reactor. Stream of referenced inners (flatmap, multicast etc)
|
| public void | |
| public void | onError(Throwable
the throwable signaled t)Implements org. |
| public void | onNext(T
the element signaled t)Implements org. Publisher in response to requests to Subscription#request(long).
|
| public void | onSubscribe(Subscription
the s)Subscription that allows requesting data via Subscription#request(long)Implements reactor. onNext(Object) before
calling Subscription#request(long).
|
| public void | request(long
the strictly positive number of elements to requests to the upstream n)PublisherImplements org. Publisher until demand is signaled via this method.
|
| public Object | scanUnsafe(Scannable.
a keyAttr to resolve for the component.Overrides default reactor. Implements reactor. |
| pack-priv void |
| actual | back to summary |
|---|---|
| pack-priv final CoreSubscriber<? super T> actual | |
| ctx | back to summary |
|---|---|
| pack-priv final Context ctx | |
| main | back to summary |
|---|---|
| pack-priv volatile Subscription main | |
| MAIN | back to summary |
|---|---|
pack-priv static final AtomicReferenceFieldUpdater<FluxSample.
| |
| other | back to summary |
|---|---|
| pack-priv volatile Subscription other | |
| OTHER | back to summary |
|---|---|
pack-priv static final AtomicReferenceFieldUpdater<FluxSample.
| |
| requested | back to summary |
|---|---|
| pack-priv volatile long requested | |
| REQUESTED | back to summary |
|---|---|
pack-priv static final AtomicLongFieldUpdater<FluxSample.
| |
| value | back to summary |
|---|---|
| pack-priv volatile T value | |
| VALUE | back to summary |
|---|---|
pack-priv static final AtomicReferenceFieldUpdater<FluxSample.
| |
| SampleMainSubscriber | back to summary |
|---|---|
| pack-priv SampleMainSubscriber(CoreSubscriber<? super T> actual) | |
| actual | back to summary |
|---|---|
| public final CoreSubscriber Implements reactor.
| |
| cancel | back to summary |
|---|---|
| public void cancel() Implements org. Doc from org. Request the Data may still be sent to meet previously signalled demand after calling cancel.
| |
| cancelMain | back to summary |
|---|---|
| pack-priv void cancelMain() | |
| cancelOther | back to summary |
|---|---|
| pack-priv void cancelOther() | |
| decrement | back to summary |
|---|---|
| pack-priv void decrement() | |
| getAndNullValue | back to summary |
|---|---|
pack-priv T getAndNullValue()
| |
| inners | back to summary |
|---|---|
| public Stream Overrides default reactor. Doc from reactor. Return a | |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements org. Doc from org. Successful terminal state.
No further events will be sent even if
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Implements org. Doc from org. Failed terminal state.
No further events will be sent even if | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements org. Doc from org. Data notification sent by the
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Subscription s) Implements reactor. Doc from reactor. Implementors should initialize any state used by
Note that an invalid request
No data will start flowing until
It is the responsibility of this
The
| |
| request | back to summary |
|---|---|
| public void request(long n) Implements org. Doc from org. No events will be sent by a
It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more,
it may be treated by the
Whatever has been requested can be sent by the
A | |
| scanUnsafe | back to summary |
|---|---|
| public Object scanUnsafe(Scannable. Overrides default reactor. Implements reactor. Doc from reactor. This method is used internally by components to define their key-value mappings
in a single place. Although it is ignoring the generic type of the
For public consumption of attributes, prefer using | |
| setOther | back to summary |
|---|---|
| pack-priv void setOther(Subscription s) | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final FluxSample. |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public Context | currentContext()
Overrides default reactor. Context from dependent components which can include downstream
operators during subscribing or a terminal org..
|
| public void | |
| public void | onError(Throwable
the throwable signaled t)Implements org. |
| public void | onNext(U
the element signaled t)Implements org. Publisher in response to requests to Subscription#request(long).
|
| public void | onSubscribe(Subscription
the s)Subscription that allows requesting data via Subscription#request(long)Implements reactor. onNext(Object) before
calling Subscription#request(long).
|
| public Object | scanUnsafe(Scannable.
a keyAttr to resolve for the component.Implements reactor. |
| main | back to summary |
|---|---|
| pack-priv final FluxSample. | |
| SampleOther | back to summary |
|---|---|
| pack-priv SampleOther(FluxSample. | |
| currentContext | back to summary |
|---|---|
| public Context currentContext() Overrides default reactor. Doc from reactor. Request a
| |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements org. Doc from org. Successful terminal state.
No further events will be sent even if
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Implements org. Doc from org. Failed terminal state.
No further events will be sent even if | |
| onNext | back to summary |
|---|---|
| public void onNext(U t) Implements org. Doc from org. Data notification sent by the
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Subscription s) Implements reactor. Doc from reactor. Implementors should initialize any state used by
Note that an invalid request
No data will start flowing until
It is the responsibility of this
The
| |
| scanUnsafe | back to summary |
|---|---|
| public Object scanUnsafe(Scannable. Implements reactor. Doc from reactor. This method is used internally by components to define their key-value mappings
in a single place. Although it is ignoring the generic type of the
For public consumption of attributes, prefer using | |