Skip navigation links
Spring Data MongoDB
org.springframework.data.mongodb.core

Class ReactiveMongoContext


  • public class ReactiveMongoContext
extends Object
    ReactiveMongoContext utilizes and enriches the Reactor Context with information potentially required for e.g. ClientSession handling and transactions.
    Since:
    2.1
    Author:
    Christoph Strobl, Mark Paluch
    See Also:
    Mono.subscriberContext(), Context

    • Constructor Detail

      • ReactiveMongoContext

        public ReactiveMongoContext()

    • Method Detail

      • getSession

        public static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.ClientSession> getSession()
        Gets the Mono<ClientSession> from Reactor Context. The resulting Mono emits the ClientSession if a session is associated with the current subscriber context. If the context does not contain a session, the resulting Mono terminates empty (i.e. without emitting a value).
        Returns:
        the Mono emitting the client session if present; otherwise the Mono terminates empty.

      • setSession

        public static reactor.util.context.Context setSession(reactor.util.context.Context context,
                                                      org.reactivestreams.Publisher<com.mongodb.reactivestreams.client.ClientSession> session)
        Sets the ClientSession into the Reactor Context.
        Parameters:
        context - must not be null.
        session - must not be null.
        Returns:
        a new Context.
        See Also:
        Context.put(Object, Object)
Skip navigation links
Spring Data MongoDB


Impressum und Datenschutz    Copyright ©2018 eir.me