public interface ReactiveSessionScoped
ClientSession
bound operations against MongoDB via a
ReactiveSessionCallback
.Modifier and Type | Method and Description |
---|---|
default <T> reactor.core.publisher.Flux<T> |
execute(ReactiveSessionCallback<T> action)
Executes the given
ReactiveSessionCallback within the ClientSession . |
<T> reactor.core.publisher.Flux<T> |
execute(ReactiveSessionCallback<T> action,
Consumer<com.mongodb.reactivestreams.client.ClientSession> doFinally)
Executes the given
ReactiveSessionCallback within the ClientSession . |
default <T> reactor.core.publisher.Flux<T> execute(ReactiveSessionCallback<T> action)
ReactiveSessionCallback
within the ClientSession
.
It is up to the caller to make sure the ClientSession
is closed
when done.T
- return type.action
- callback object that specifies the MongoDB action the callback action. Must not be null.Flux.empty()
.<T> reactor.core.publisher.Flux<T> execute(ReactiveSessionCallback<T> action, Consumer<com.mongodb.reactivestreams.client.ClientSession> doFinally)
ReactiveSessionCallback
within the ClientSession
.
It is up to the caller to make sure the ClientSession
is closed
when done.T
- return type.action
- callback object that specifies the MongoDB action the callback action. Must not be null.doFinally
- callback object that accepts ClientSession
after invoking ReactiveSessionCallback
.
This Consumer
is guaranteed to be notified in any case (successful and exceptional outcome of
ReactiveSessionCallback
).Flux.empty()
.Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.