@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. Please note that only Spring Data-specific abstractions like
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–2021 Pivotal Software, Inc.. All rights reserved.