LiveDataToRS.java

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