MongoDB reactive stream asynchronous processing examples with CompletableFuture

Working with Data Drivers & ODMs
#1

Hi Team,

I need some support on the usage of MongoDB reactive streams for asynchronous processing .

How can i use of MongoDB reactive streams along with CompletableFufure for asynchronous processing or

is there any other way than CompletableFuture to achieve asynchronous processing with MongoDB reactive streams?

Thanks in Adavance :slight_smile:

Regards,
Akshay

#2

You can use https://github.com/akarnokd/RxJavaJdk8Interop to convert reactive types to CompletableFuture. We have been using it while migrating our app to reactive streams. However, I really would like to recommend to check out more about reactive streams and consider fully writing your app that way.