Class ReactiveMongoContext
java.lang.Object
org.springframework.data.mongodb.core.ReactiveMongoContext
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:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic Mono<com.mongodb.reactivestreams.client.ClientSession>
Gets theMono<ClientSession>
from ReactorContext
.static Context
setSession
(Context context, Publisher<com.mongodb.reactivestreams.client.ClientSession> session) Sets theClientSession
into the ReactorContext
.
-
Constructor Details
-
ReactiveMongoContext
public ReactiveMongoContext()
-
-
Method Details
-
getSession
Gets theMono<ClientSession>
from ReactorContext
. The resultingMono
emits theClientSession
if a session is associated with the currentsubscriber context
. If the context does not contain a session, the resultingMono
terminates empty (i.e. without emitting a value). -
setSession
public static Context setSession(Context context, Publisher<com.mongodb.reactivestreams.client.ClientSession> session) Sets theClientSession
into the ReactorContext
.- Parameters:
context
- must not be null.session
- must not be null.- Returns:
- a new
Context
. - See Also:
-