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