Package org.springframework.data.mongodb.core

Class ReactiveMongoContext

java.lang.Object
org.springframework.data.mongodb.core.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.deferContextual(Function)
  • Context

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveMongoContext()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.ClientSession>
    getSession()
    Gets the Mono<ClientSession> from Reactor Context.
    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.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactiveMongoContext

      public ReactiveMongoContext()

  • Method Details

    • 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)