rxJava

QRCP supports the rxJava. Use class ObservableMapper.

ObservableMapper.queryAll(TestEntity.class)
.flatMap(Observable::from)
.map(entity -> entity.getName())
.doOnNext(System.out::println)
.subscribe();