Convert between RxJava and Agera reactive base types - View it on GitHub