1.0.0
Version 1.0.0 release along with Reactive Streams 1.0.0.
A Reactive Stream Publisher
can be created from an Observable
like this:
// Create a publisher
Observable<Integer> observable = Observable.from(ints);
Publisher<Integer> publisher = RxReactiveStreams.toPublisher(observable);
And a Publisher
can be converted to an Observable
like this:
// Convert to an Rx Observable to do further transforms
Observable<String> lines = RxReactiveStreams.toObservable(stringsPublisher);
The artifact is available on Maven Central and can be imported with this dependency information:
<dependency>
<groupId>io.reactivex</groupId>
<artifactId>rxjava-reactive-streams</artifactId>
<version>1.0.0</version>
</dependency>
compile 'io.reactivex:rxjava-reactive-streams:1.0.0'