Package com.couchbase.client.core.transaction

Class CoreTransactionsReactive

java.lang.Object

com.couchbase.client.core.transaction.CoreTransactionsReactive

@Internal
public class CoreTransactionsReactive
extends Object

Constructor Summary

Constructors

Constructor	Description
CoreTransactionsReactive(Core core, CoreTransactionsConfig config)

Method Summary

Modifier and Type	Method	Description
CoreTransactionsConfig	config()
Core	core()
reactor.core.publisher.Mono<CoreReactiveQueryResult>	query(String statement, CoreQueryContext queryContext, CoreQueryOptions queryOptions, Optional<RequestSpan> parentSpan, Function<Throwable,RuntimeException> errorConverter)	Performs a single query transaction, with a scope context and custom configuration.
reactor.core.publisher.Mono<CoreQueryResult>	queryBlocking(String statement, CoreQueryContext qc, CoreQueryOptions queryOptions, Optional<RequestSpan> parentSpan)
reactor.core.publisher.Mono<CoreTransactionResult>	run(Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<?>> transactionLogic, CoreTransactionOptions perConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

CoreTransactionsReactive

public CoreTransactionsReactive(Core core,
 CoreTransactionsConfig config)

Method Details

run

public reactor.core.publisher.Mono<CoreTransactionResult> run(Function<CoreTransactionAttemptContext,reactor.core.publisher.Mono<?>> transactionLogic,
 @Nullable
 CoreTransactionOptions perConfig)

config

public CoreTransactionsConfig config()

core

public Core core()

query

public reactor.core.publisher.Mono<CoreReactiveQueryResult> query(String statement,
 @Nullable
 CoreQueryContext queryContext,
 CoreQueryOptions queryOptions,
 Optional<RequestSpan> parentSpan,
 Function<Throwable,RuntimeException> errorConverter)

Performs a single query transaction, with a scope context and custom configuration. Results are streaming, hence `errorConverter` is required to handle any errors during streaming.

queryBlocking

public reactor.core.publisher.Mono<CoreQueryResult> queryBlocking(String statement,
 @Nullable
 CoreQueryContext qc,
 CoreQueryOptions queryOptions,
 Optional<RequestSpan> parentSpan)