Package com.couchbase.client.core.api.kv

Class CoreAsyncResponse<T>

java.lang.Object

com.couchbase.client.core.api.kv.CoreAsyncResponse<T>

@Internal
public final class CoreAsyncResponse<T>
extends Object

Associates a CompletableFuture with a cancellation task.

Lets the Async API tell the Reactive API how to cancel a request in a protocol-agnostic way, so the default implementation of the Reactive API works with both Classic and Protostellar.

A CompletableFuture alone is not sufficient, because a completion stage does not propagate cancellation upstream. If the Async API methods were to return only a CompletableFuture, they could not reliably attach the cancellation logic required by the Reactive API methods (which by default are thin wrappers over the Async APIs).

Constructor Summary

Constructors

Constructor	Description
CoreAsyncResponse(CompletableFuture<T> future, Runnable cancellationTask)

Method Summary

Modifier and Type	Method	Description
<U> CoreAsyncResponse<U>	flatMap(Function<? super T,? extends CoreAsyncResponse<U>> fn)
<U> CoreAsyncResponse<U>	map(Function<? super T,? extends U> fn)
<U> CompletableFuture<U>	thenApply(Function<? super T,? extends U> fn)
<U> CompletableFuture<U>	thenCompose(Function<? super T,? extends CompletableFuture<U>> fn)
T	toBlocking()
CompletableFuture<T>	toFuture()
CompletableFuture<Void>	toFutureVoid()
Mono<T>	toMono()

Methods inherited from class java.lang.Object

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

Constructor Details

CoreAsyncResponse

public CoreAsyncResponse(CompletableFuture<T> future,
 Runnable cancellationTask)

Method Details

toBlocking

public T toBlocking()

toFuture

public CompletableFuture<T> toFuture()

toFutureVoid

public CompletableFuture<Void> toFutureVoid()

toMono

public Mono<T> toMono()

thenApply

public <U> CompletableFuture<U> thenApply(Function<? super T,? extends U> fn)

thenCompose

public <U> CompletableFuture<U> thenCompose(Function<? super T,? extends CompletableFuture<U>> fn)

map

public <U> CoreAsyncResponse<U> map(Function<? super T,? extends U> fn)

flatMap

public <U> CoreAsyncResponse<U> flatMap(Function<? super T,? extends CoreAsyncResponse<U>> fn)