public class ReactiveMongoContext extends Object
ReactiveMongoContext utilizes and enriches the Reactor Context with information potentially required
for e.g. ClientSession handling and transactions.Mono.deferContextual(Function),
Context| Constructor and Description |
|---|
ReactiveMongoContext() |
| Modifier and Type | Method and 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. |
public static reactor.core.publisher.Mono<com.mongodb.reactivestreams.client.ClientSession> getSession()
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).Mono emitting the client session if present; otherwise the Mono terminates empty.public static reactor.util.context.Context setSession(reactor.util.context.Context context,
org.reactivestreams.Publisher<com.mongodb.reactivestreams.client.ClientSession> session)
ClientSession into the Reactor Context.context - must not be null.session - must not be null.Context.Context.put(Object, Object)Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.