Adapter between RxJava and ReactiveStreams