rxjava worker thread example

sample.java

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);
                }
            }
        });