NAME
RxT4A - RxJava Toolbox for Android
SYNOPSIS
// AndroidSchedulers Scheduler scheduler = AndroidSchedulers.mainThread();
Scheduler scheduler = AndroidSchedulers.from(new Handler());
// AndroidCompositeSubscription final AndroidCompositeSubscription s = new AndroidCompositeSubscription();
s.add(subscription1);
s.add(subscription2);
s.unsubscribe();
// unsubscribe 1 and 2 // it is reusable! s.add(subscription3);
s.add(subscription4);
s.unsubscribe();
// unsubscribe 3 and 4, too! // OperatorAddToCompositeSubscription Observable.just("foo")
.lift(new OperatorAddToCompositeSubscription<String>(s))
.delay(5, TimeUnit.MILLISECONDS)
.subscribe(...);
s.unsubscribe();
// unsubscribe the above subscriptionDESCRIPTION
This is a fork of RxAndroid.
AndroidSchedulers
This is almost the same as RxAndroid's AndroidSchedulers.
AndroidCompositeSubscription
This is a variation of CompositeSubscription but can be reused multiple times.
OperatorAddToCompositeSubscription
Add a subscription to AndroidCompositeSubscription in operator chains.
AndroidSubscriptions
This class provides a way to create subscriptions for Android applications.
Subscription subscription = observable.subscribe(subscriber);
// Like Subscriptions.create(Action0), but the action is called on the main thread. subscription.add(AndroidSubscriptions.unsubscribeOnMainThread(new Action0() {
@Override
public void call() {
// You can touch touch views.
}
}
));
INSTALL
dependencies {
compile 'com.cookpad.android.rxt4a:rxt4a:1.0.0'
}
LICENSE
The MIT License
AUTHOR
Cookpad Inc.