Uses of Class
com.couchbase.client.core.api.kv.CoreAsyncResponse

Packages that use CoreAsyncResponse

Package	Description
com.couchbase.client.core.api.kv
com.couchbase.client.core.api.query
com.couchbase.client.core.api.search
com.couchbase.client.core.classic
com.couchbase.client.core.classic.kv
com.couchbase.client.core.classic.query
com.couchbase.client.core.protostellar
com.couchbase.client.core.protostellar.kv
com.couchbase.client.core.protostellar.query
com.couchbase.client.core.protostellar.search

Uses of CoreAsyncResponse in com.couchbase.client.core.api.kv

Methods in com.couchbase.client.core.api.kv that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreMutationResult>	CoreKvBinaryOps.appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	CoreKvBinaryOps.decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreExistsResult>	CoreKvOps.existsAsync(CoreCommonOptions common, String key)
<U> CoreAsyncResponse<U>	CoreAsyncResponse.flatMap(Function<? super T,? extends CoreAsyncResponse<U>> fn)
CoreAsyncResponse<CoreGetResult>	CoreKvOps.getAndLockAsync(CoreCommonOptions common, String key, Duration lockTime)
CoreAsyncResponse<CoreGetResult>	CoreKvOps.getAndTouchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<CoreGetResult>	CoreKvOps.getAsync(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
CoreAsyncResponse<CoreCounterResult>	CoreKvBinaryOps.incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
<U> CoreAsyncResponse<U>	CoreAsyncResponse.map(Function<? super T,? extends U> fn)
CoreAsyncResponse<CoreMutationResult>	CoreKvBinaryOps.prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durabilityLevel)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreAsyncResponse<CoreSubdocGetResult>	CoreKvOps.subdocGetAsync(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
CoreAsyncResponse<CoreSubdocMutateResult>	CoreKvOps.subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.touchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<Void>	CoreKvOps.unlockAsync(CoreCommonOptions common, String key, long cas)
CoreAsyncResponse<CoreMutationResult>	CoreKvOps.upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)

Method parameters in com.couchbase.client.core.api.kv with type arguments of type CoreAsyncResponse

Modifier and Type	Method	Description
<U> CoreAsyncResponse<U>	CoreAsyncResponse.flatMap(Function<? super T,? extends CoreAsyncResponse<U>> fn)

Uses of CoreAsyncResponse in com.couchbase.client.core.api.query

Methods in com.couchbase.client.core.api.query that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreQueryResult>	CoreQueryOps.queryAsync(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)

Uses of CoreAsyncResponse in com.couchbase.client.core.api.search

Methods in com.couchbase.client.core.api.search that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreSearchResult>	ClassicCoreSearchOps.searchAsync(String indexName, CoreSearchRequest searchRequest, CoreSearchOptions options)
CoreAsyncResponse<CoreSearchResult>	CoreSearchOps.searchAsync(String indexName, CoreSearchRequest searchRequest, CoreSearchOptions options)
CoreAsyncResponse<CoreSearchResult>	ClassicCoreSearchOps.searchQueryAsync(String indexName, CoreSearchQuery query, CoreSearchOptions options)
CoreAsyncResponse<CoreSearchResult>	CoreSearchOps.searchQueryAsync(String indexName, CoreSearchQuery query, CoreSearchOptions options)

Uses of CoreAsyncResponse in com.couchbase.client.core.classic

Methods in com.couchbase.client.core.classic that return CoreAsyncResponse

Modifier and Type	Method	Description
static <T, RES extends Response> CoreAsyncResponse<T>	ClassicHelper.newAsyncResponse(Request<RES> request, CompletableFuture<T> future)	Returns a new async response whose cancellation task calls Request.cancel(CancellationReason).

Uses of CoreAsyncResponse in com.couchbase.client.core.classic.kv

Methods in com.couchbase.client.core.classic.kv that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvBinaryOps.appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)	Appends binary content to the document with custom options.
CoreAsyncResponse<CoreCounterResult>	ClassicCoreKvBinaryOps.decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)	Decrements the counter document by one or the number defined in the options.
CoreAsyncResponse<CoreExistsResult>	ClassicCoreKvOps.existsAsync(CoreCommonOptions common, String key)
CoreAsyncResponse<CoreGetResult>	ClassicCoreKvOps.getAndLockAsync(CoreCommonOptions common, String key, Duration lockTime)
CoreAsyncResponse<CoreGetResult>	ClassicCoreKvOps.getAndTouchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<CoreGetResult>	ClassicCoreKvOps.getAsync(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
CoreAsyncResponse<CoreCounterResult>	ClassicCoreKvBinaryOps.incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)	Increments the counter document by one or the number defined in the options.
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvBinaryOps.prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)	Prepends binary content to the document with custom options.
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreAsyncResponse<CoreSubdocGetResult>	ClassicCoreKvOps.subdocGetAsync(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
CoreAsyncResponse<CoreSubdocMutateResult>	ClassicCoreKvOps.subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.touchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<Void>	ClassicCoreKvOps.unlockAsync(CoreCommonOptions common, String key, long cas)
CoreAsyncResponse<CoreMutationResult>	ClassicCoreKvOps.upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)

Uses of CoreAsyncResponse in com.couchbase.client.core.classic.query

Methods in com.couchbase.client.core.classic.query that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreQueryResult>	ClassicCoreQueryOps.queryAsync(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)

Uses of CoreAsyncResponse in com.couchbase.client.core.protostellar

Methods in com.couchbase.client.core.protostellar that return CoreAsyncResponse

Modifier and Type	Method	Description
static <TSdkResult, TGrpcRequest, TGrpcResponse> CoreAsyncResponse<TSdkResult>	CoreProtostellarAccessors.async(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint,com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse,TSdkResult> convertResponse)	Convenience overload that uses the default exception handling.
static <TSdkResult, TGrpcRequest, TGrpcResponse> CoreAsyncResponse<TSdkResult>	CoreProtostellarAccessors.async(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, Function<ProtostellarEndpoint,com.couchbase.client.core.deps.com.google.common.util.concurrent.ListenableFuture<TGrpcResponse>> executeFutureGrpcCall, Function<TGrpcResponse,TSdkResult> convertResponse, Function<Throwable,ProtostellarRequestBehaviour> convertException)
static <TGrpcRequest, TGrpcResponse> CoreAsyncResponse<List<TGrpcResponse>>	CoreProtostellarAccessorsStreaming.async(CoreProtostellar core, ProtostellarRequest<TGrpcRequest> request, BiConsumer<ProtostellarEndpoint,com.couchbase.client.core.deps.io.grpc.stub.StreamObserver<TGrpcResponse>> executeFutureGrpcCall, Function<Throwable,ProtostellarRequestBehaviour> convertException)

Uses of CoreAsyncResponse in com.couchbase.client.core.protostellar.kv

Methods in com.couchbase.client.core.protostellar.kv that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvBinaryOps.appendAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreAsyncResponse<CoreCounterResult>	ProtostellarCoreKvBinaryOps.decrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreExistsResult>	ProtostellarCoreKvOps.existsAsync(CoreCommonOptions common, String key)
CoreAsyncResponse<CoreGetResult>	ProtostellarCoreKvOps.getAndLockAsync(CoreCommonOptions common, String key, Duration lockTime)
CoreAsyncResponse<CoreGetResult>	ProtostellarCoreKvOps.getAndTouchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<CoreGetResult>	ProtostellarCoreKvOps.getAsync(CoreCommonOptions common, String key, List<String> projections, boolean withExpiry)
CoreAsyncResponse<CoreCounterResult>	ProtostellarCoreKvBinaryOps.incrementAsync(String id, CoreCommonOptions options, CoreExpiry expiry, long delta, Optional<Long> initial, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.insertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvBinaryOps.prependAsync(String id, byte[] content, CoreCommonOptions options, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.removeAsync(CoreCommonOptions common, String key, long cas, CoreDurability durability)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.replaceAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)
CoreAsyncResponse<CoreSubdocGetResult>	ProtostellarCoreKvOps.subdocGetAsync(CoreCommonOptions common, String key, List<CoreSubdocGetCommand> commands, boolean accessDeleted)
CoreAsyncResponse<CoreSubdocMutateResult>	ProtostellarCoreKvOps.subdocMutateAsync(CoreCommonOptions common, String key, Supplier<List<CoreSubdocMutateCommand>> commands, CoreStoreSemantics storeSemantics, long cas, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry, boolean accessDeleted, boolean createAsDeleted)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.touchAsync(CoreCommonOptions common, String key, CoreExpiry expiry)
CoreAsyncResponse<Void>	ProtostellarCoreKvOps.unlockAsync(CoreCommonOptions common, String key, long cas)
CoreAsyncResponse<CoreMutationResult>	ProtostellarCoreKvOps.upsertAsync(CoreCommonOptions common, String key, Supplier<CoreEncodedContent> content, CoreDurability durability, CoreExpiry expiry, boolean preserveExpiry)

Uses of CoreAsyncResponse in com.couchbase.client.core.protostellar.query

Methods in com.couchbase.client.core.protostellar.query that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreQueryResult>	ProtostellarCoreQueryOps.queryAsync(String statement, CoreQueryOptions options, CoreQueryContext queryContext, NodeIdentifier target, Function<Throwable,RuntimeException> errorConverter)

Uses of CoreAsyncResponse in com.couchbase.client.core.protostellar.search

Methods in com.couchbase.client.core.protostellar.search that return CoreAsyncResponse

Modifier and Type	Method	Description
CoreAsyncResponse<CoreSearchResult>	ProtostellarCoreSearchOps.searchAsync(String indexName, CoreSearchRequest searchRequest, CoreSearchOptions options)
CoreAsyncResponse<CoreSearchResult>	ProtostellarCoreSearchOps.searchQueryAsync(String indexName, CoreSearchQuery search, CoreSearchOptions options)