Description
Nilesh Mevada opened DATACOUCH-343 and commented
Hi,
I am using reactive workflow of spring-data-couchbase:3.0.0.RC2 (automatically pulled by Spring Boot 2.0.0.M3).
RxJava2 allows transition from/to ReactiveStreams types. I use Reactor for my reactive workflows. However, while using following code gives me compilation error.
//repository is of type - ReactiveCouchbaseSortingRepository<>
Observable<User> observable = repository.getCouchbaseOperations().findByN1QL(query, User.class); // #1
return Flux.from(observable.toFlowable(BackpressureStrategy.BUFFER)); // #2
Now, #1 returns rx.Observable which is from RxJava1. This does not allow me to use #2 (which tries to convert RxJava2's Observable to Reactor's Flow class).
Even though I force my project build to use RxJava2; it won't work, because, as of spring-data-couchbase:3.0.0.RC2, the code still uses RxJava1.
So, is it possible to change the dependent library from RxJava1 to RxJava2? That would really be helpful. And, when can we possibly expect it to be available?
Notes :
- I have marked 3.0 GA version whereas my code is against 3.0.0.RC2 version (as that is what spring boot automatically pulls in.)
PS : Hope I have given enough details. Let me know if I haven't.
Affects: 3.0 GA (Kay)