Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
LiveData<List<Integer>> ld = LiveDataReactiveStreams.fromPublisher(
Flowable.range(1, 5)
.delay(500, TimeUnit.MILLISECONDS)
.toList()
.toFlowable()
);
Log.d("TAG", "Sleep");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
ld.observe(this, o -> {
Log.d("TAG", o.toString());
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment