MongoDB reactive stream asynchronous processing examples with CompletableFuture

Working with Data Drivers
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 GitHub - akarnokd/RxJavaJdk8Interop: RxJava 2/3 interop library for supporting Java 8 features such as Optional, Stream and CompletableFuture [discontinued] 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.