Package io.micronaut.data.mongodb.operations

Interface MongoReactorRepositoryOperations

All Superinterfaces:

MongoReactiveRepositoryOperations, ReactiveRepositoryOperations, ReactiveTransactionOperations<com.mongodb.reactivestreams.client.ClientSession>, ReactorReactiveTransactionOperations<com.mongodb.reactivestreams.client.ClientSession>

All Known Implementing Classes:

DefaultReactiveMongoRepositoryOperations

public interface MongoReactorRepositoryOperations
extends MongoReactiveRepositoryOperations, ReactorReactiveTransactionOperations<com.mongodb.reactivestreams.client.ClientSession>

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

Nested Class Summary

Nested classes/interfaces inherited from interface io.micronaut.transaction.reactive.ReactiveTransactionOperations

ReactiveTransactionOperations.TransactionalCallback<C,T>

Field Summary

Fields inherited from interface io.micronaut.transaction.reactive.ReactorReactiveTransactionOperations

TRANSACTION_DEFINITION_KEY_PREFIX, TRANSACTION_STATUS_KEY_PREFIX

Method Summary

Modifier and Type	Method	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.

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

Methods inherited from interface io.micronaut.transaction.reactive.ReactorReactiveTransactionOperations

getTransactionDefinition, getTransactionStatus, withTransaction, withTransaction, withTransactionFlux, withTransactionFlux, withTransactionMono, withTransactionMono

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