io.micronaut.data.mongodb.operations

Interface MongoReactorRepositoryOperations

All Superinterfaces:

MongoReactiveRepositoryOperations, ReactiveRepositoryOperations

All Known Implementing Classes:

DefaultReactiveMongoRepositoryOperations

public interface MongoReactorRepositoryOperations
extends MongoReactiveRepositoryOperations

A variation of MongoReactiveRepositoryOperations with Reactor specific method to execute an operation with the contextual ClientSession.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CLIENT_SESSION_CONTEXT_KEY The property name for the ClientSession stored in Reactor's context.

Method Summary

Modifier and Type	Method and Description
<T> reactor.core.publisher.Mono<T>	withClientSession(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Mono<? extends T>> function) Starts a new session or reuses one from the context.
<T> reactor.core.publisher.Flux<T>	withClientSessionMany(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Flux<? extends T>> function) Starts a new session or reuses one from the context.
<T> org.reactivestreams.Publisher<T>	withTransaction(ReactiveTransactionStatus<com.mongodb.reactivestreams.client.ClientSession> status, ReactiveTransactionOperations.TransactionalCallback<com.mongodb.reactivestreams.client.ClientSession,T> handler) Execute the given handler with a new transaction.

Methods inherited from interface io.micronaut.data.operations.reactive.ReactiveRepositoryOperations

count, delete, deleteAll, executeDelete, executeUpdate, exists, findAll, findAll, findOne, findOne, findOptional, findOptional, findPage, persist, persistAll, update, updateAll

Field Detail

CLIENT_SESSION_CONTEXT_KEY

static final java.lang.String CLIENT_SESSION_CONTEXT_KEY

The property name for the ClientSession stored in Reactor's context.

See Also:

Constant Field Values

Method Detail

withClientSession

<T> reactor.core.publisher.Mono<T> withClientSession(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Mono<? extends T>> function)

Starts a new session or reuses one from the context.

Type Parameters:

T - The emitted type

Parameters:

function - The function

Returns:

The processed publisher

withClientSessionMany

<T> reactor.core.publisher.Flux<T> withClientSessionMany(java.util.function.Function<com.mongodb.reactivestreams.client.ClientSession,reactor.core.publisher.Flux<? extends T>> function)

Starts a new session or reuses one from the context.

Type Parameters:

T - The emitted type

Parameters:

function - The function

Returns:

The processed publisher

withTransaction

<T> org.reactivestreams.Publisher<T> withTransaction(@NonNull
                                                     ReactiveTransactionStatus<com.mongodb.reactivestreams.client.ClientSession> status,
                                                     @NonNull
                                                     ReactiveTransactionOperations.TransactionalCallback<com.mongodb.reactivestreams.client.ClientSession,T> handler)

Execute the given handler with a new transaction.

Type Parameters:

T - The emitted type

Parameters:

status - The tx status

handler - The handler

Returns:

A publisher that emits the result type