pyadav

public class HomePresenterImpl implements HomePresenter {
	private static final String TAG = HomePresenterImpl.class.getSimpleName();
	private final HomeScreen screen;
	private final DataProvider provider;
	private Subscription subscription1;

	public HomePresenterImpl(HomeScreenImpl screen, DataProvider dataProvider) {
		this.screen = screen;
		this.provider = dataProvider;
	}

pyadav

public class GcmRegistrationIntentService extends IntentService {

    private static final String TAG = "RegIntentService";
    private static final String[] TOPICS = {"global"};

    private PushNotificationManager pushNotificationManager;
    private GcmRequestManager gcmRequestManager;
    private InstanceID instanceID;

    public GcmRegistrationIntentService() {

pyadav

final Scheduler.Worker worker = Schedulers.newThread().createWorker();
        worker.schedule(new Action0() {
            @Override
            public void call() {
                if (!mAnimationSet.isStarted()) {
                    removeViewAt(0);
                    worker.unsubscribe();
                } else {
                    worker.schedule(this, 500, TimeUnit.MILLISECONDS);
                }

pyadav

#build.gradle
#
#    compile 'io.reactivex:rxandroid:1.0.1'
#    compile 'io.reactivex:rxjava:1.0.14'
#    compile 'io.reactivex:rxjava-math:1.0.0'
#    compile 'com.jakewharton.rxbinding:rxbinding:0.2.0'

# rxjava
-keep class rx.schedulers.Schedulers {
    public static <methods>;

pyadav

// slide 75 of this: http://www.slideshare.net/Couchbase/reactive-programmingrxjavaefficientdata-benchristensenmichaelnitschinger

Observable.
  .defer(() -> bucket.get("id")) //create new
  .retryWhen(attempts -> attempts
      .zipWith(Observable.range(1,3), (n, i) -> i) // retry maximum of 3 times
      .flatMap(i -> {
        System.out.println("Delaying retry by " + i + " second(s)");
        return Observable.timer(i, TimeUnit.SECONDS); //delay the resubscribe
      })

pyadav

import rx.Observable

interface RxPermission {
    val isGranted: Boolean

    fun request(): Observable<Boolean>
}

pyadav

// sample 3 UI event
mButton = (Button) findViewById(R.id.button);
Observable<View> clickEventObservable = Observable.create(new Observable.OnSubscribe<View>() {
    @Override
    public void call(final Subscriber<? super View> subscriber) {
        mButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                subscriber.onNext(v);
            }

pyadav

package com.company;

import retrofit.RestAdapter;
import retrofit.http.GET;
import retrofit.http.Path;
import rx.Observable;
import rx.Subscriber;
import rx.functions.Action1;
import rx.functions.Func1;
import rx.functions.Func2;

pyadav

public abstract class CachedRefreshable<P, T> extends Refreshable<P, T> {

    protected abstract Observable<T> getSourceObservable(P parameters);

    /**
     * Return the Observable that gets data from a cached source.
     *
     * @return Observable from cache item, or null if the cache misses.
     */
    protected abstract Observable<T> getCachedObservable(P parameters);

pyadav

package rx.concurrency;

import android.os.Handler;
import android.os.Looper;
import rx.Scheduler;
import rx.Subscription;
import rx.concurrency.ExecutorScheduler;
import rx.util.AtomicObservableSubscription;
import rx.util.functions.Func2;