@FunctionalInterface public interface ReactiveSessionCallback<T>
ClientSessionusing reactive infrastructure.
org.reactivestreams.Publisher<T> doInSession(ReactiveMongoOperations operations)
ReactiveMongoOperations. The session is inferred directly into the operation so that no further interaction is necessary.
ReactiveMongoOperations.find(Query, Class)and others are enhanced with the
ClientSession. When obtaining plain MongoDB gateway objects like
ReactiveMongoOperations.getCollection(String)we leave responsibility for
ClientSessionagain up to the caller.
operations- will never be null.
Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.