| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class | |
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Scheduler |
| 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 Timed<T>> actual)
Implements abstract reactor. Implements reactor. CoreSubscriber, or force
subscription encapsulation by returning null.
|
| clock | back to summary |
|---|---|
| pack-priv final Scheduler clock | |
| FluxTimed | back to summary |
|---|---|
| pack-priv FluxTimed(Flux<? extends T> source, Scheduler clock) | |
| 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
| |
Timed. This is preferable to the subscriber implementing
Timed interface, as timestamps are likely to be collected for later use (so flyweight
would get in the way).
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final T | |
| pack-priv final long | |
| pack-priv final long | |
| pack-priv final long |
| Access | Constructor and Description |
|---|---|
| pack-priv | ImmutableTimed(long eventElapsedSinceSubscriptionNanos, long eventElapsedNanos, long eventTimestampEpochMillis, T event)
|
| Modifier and Type | Method and Description |
|---|---|
| public Duration | elapsed()
Implements reactor. Duration since the previous onNext (or onSubscribe in
case this represents the first onNext).
|
| public Duration | elapsedSinceSubscription()
Implements reactor. Duration since the subscription (onSubscribe signal).
|
| public boolean | equals(Object
the reference object with which to compare. o)Overrides java. |
| public T | |
| public int | |
| public Instant | timestamp()
Implements reactor. Instant.
|
| public String |
| event | back to summary |
|---|---|
| pack-priv final T event | |
| eventElapsedNanos | back to summary |
|---|---|
| pack-priv final long eventElapsedNanos | |
| eventElapsedSinceSubscriptionNanos | back to summary |
|---|---|
| pack-priv final long eventElapsedSinceSubscriptionNanos | |
| eventTimestampEpochMillis | back to summary |
|---|---|
| pack-priv final long eventTimestampEpochMillis | |
| ImmutableTimed | back to summary |
|---|---|
| pack-priv ImmutableTimed(long eventElapsedSinceSubscriptionNanos, long eventElapsedNanos, long eventTimestampEpochMillis, T event) | |
| elapsed | back to summary |
|---|---|
| public Duration elapsed() Implements reactor. Doc from reactor. Get the elapsed | |
| elapsedSinceSubscription | back to summary |
|---|---|
| public Duration elapsedSinceSubscription() Implements reactor. Doc from reactor. Get the elapsed | |
| equals | back to summary |
|---|---|
| public boolean equals(Object o) Overrides java. Doc from java. Indicates whether some other object is "equal to" this one.
The
An equivalence relation partitions the elements it operates on into equivalence classes; all the members of an equivalence class are equal to each other. Members of an equivalence class are substitutable for each other, at least for some purposes. | |
| get | back to summary |
|---|---|
| public T get() Implements reactor. Doc from reactor. Get the value wrapped by this
| |
| hashCode | back to summary |
|---|---|
| public int hashCode() Overrides java. Doc from java. Returns a hash code value for the object. This method is
supported for the benefit of hash tables such as those provided by
The general contract of
| |
| timestamp | back to summary |
|---|---|
| public Instant timestamp() Implements reactor. Doc from reactor. Get the timestamp of the emission of this timed onNext, as an | |
| toString | back to summary |
|---|---|
| public String toString() Overrides java. Doc from java. Returns a string representation of the object. | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final CoreSubscriber | |
| pack-priv final Scheduler | |
| pack-priv boolean | |
| pack-priv long | |
| pack-priv Subscription | |
| pack-priv long |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public CoreSubscriber | |
| public void | cancel()
Implements org. Publisher to stop sending data and clean up resources.
|
| public void | |
| public void | onError(Throwable
the throwable signaled throwable)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 l)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. |
| actual | back to summary |
|---|---|
| pack-priv final CoreSubscriber<? super Timed<T>> actual | |
| clock | back to summary |
|---|---|
| pack-priv final Scheduler clock | |
| done | back to summary |
|---|---|
| pack-priv boolean done | |
| lastEventNanos | back to summary |
|---|---|
| pack-priv long lastEventNanos | |
| s | back to summary |
|---|---|
| pack-priv Subscription s | |
| subscriptionNanos | back to summary |
|---|---|
| pack-priv long subscriptionNanos | |
| TimedSubscriber | back to summary |
|---|---|
| pack-priv TimedSubscriber(CoreSubscriber<? super Timed<T>> actual, Scheduler clock) | |
| actual | back to summary |
|---|---|
| public 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.
| |
| 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 throwable) 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 l) 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 | |