Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
rxjava worker thread example
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);
}
}
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment