RxAgera

Convert between RxJava and Agera reactive base types

Dependency

compile 'com.github.akarnokd:rxagera:0.9.0'

Usage

import static hu.akarnokd.rxagera.RxAgeraConverter.*;

import com.google.android.agera.*;

// .........

Observable o = toAgeraObservable(rx.Observable.just("Hello World!"));

o.addUpdatable(() -> System.out.println("Something happened!"));

// ;;;;;;

UpdateDispatcher ud = Observables.updateDispatcher();

rx.Observable rx = toRxObservable(ud);

rs.subscribe(() -> System.out.println("Something happened!"));

ud.update();