Package com.couchbase.client.core.util

Class LatestStateSubscription<T>

java.lang.Object

com.couchbase.client.core.util.LatestStateSubscription<T>

@Internal
public class LatestStateSubscription<T>
extends Object

Useful when only the latest value of a Flux is interesting, and processing values is relatively expensive.

Think of it as applying a hypothetical "sampleLatest" operator to the upstream flux before subscribing. In other words, it ignores all but the latest value.

Only one value is processed at a time. The processing happens asynchronously with respect to the Flux.

Requires collaboration with the subscriber; after processing each value, the subscriber must run a callback to signal readiness for the next value.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LatestStateSubscription.AsyncSubscriber<T>

Constructor Summary

Constructors

Constructor	Description
LatestStateSubscription(reactor.core.publisher.Flux<T> flux, reactor.core.scheduler.Scheduler scheduler, LatestStateSubscription.AsyncSubscriber<T> subscriber)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Void>	awaitTermination()	Returns a Mono that completes after the upstream flux terminates and its final value is completely processed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LatestStateSubscription

public LatestStateSubscription(reactor.core.publisher.Flux<T> flux,
 reactor.core.scheduler.Scheduler scheduler,
 LatestStateSubscription.AsyncSubscriber<T> subscriber)

Method Details

awaitTermination

public reactor.core.publisher.Mono<Void> awaitTermination()

Returns a Mono that completes after the upstream flux terminates and its final value is completely processed.