Package com.couchbase.client.java.transactions.internal

Class SingleQueryTransactions

java.lang.Object

com.couchbase.client.java.transactions.internal.SingleQueryTransactions

@Internal
public class SingleQueryTransactions
extends Object

Constructor Summary

Constructors

Constructor	Description
SingleQueryTransactions()

Method Summary

Modifier and Type	Method	Description
static Mono<QueryResult>	singleQueryTransactionBuffered(Core core, ClusterEnvironment environment, String statement, String bucketName, String scopeName, QueryOptions.Built opts)
static Mono<ReactiveQueryResult>	singleQueryTransactionStreaming(Core core, ClusterEnvironment environment, String statement, String bucketName, String scopeName, QueryOptions.Built opts, Consumer<RuntimeException> errorConverter)

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleQueryTransactions

public SingleQueryTransactions()

Method Detail

singleQueryTransactionBuffered

public static Mono<QueryResult> singleQueryTransactionBuffered(Core core,
                                                               ClusterEnvironment environment,
                                                               String statement,
                                                               @Nullable
                                                               String bucketName,
                                                               @Nullable
                                                               String scopeName,
                                                               QueryOptions.Built opts)

singleQueryTransactionStreaming

public static Mono<ReactiveQueryResult> singleQueryTransactionStreaming(Core core,
                                                                        ClusterEnvironment environment,
                                                                        String statement,
                                                                        @Nullable
                                                                        String bucketName,
                                                                        @Nullable
                                                                        String scopeName,
                                                                        QueryOptions.Built opts,
                                                                        Consumer<RuntimeException> errorConverter)