| |
|---|
| | |
|---|
| | /** |
|---|
| | * 受け取ったデータをFlowable/Observableに変換し、そのFlowable/Obsevableが持つデータを通知する |
|---|
| | */ |
|---|
| | public void flatmap() { |
|---|
| | public void flatmap1() { |
|---|
| | Flowable<String> flowable = Flowable.just("A", "", "B", "", "C") |
|---|
| | .flatMap(data -> { |
|---|
| | if (data.isEmpty()) { |
|---|
| | return Flowable.empty(); |
|---|
| |
|---|
| | } |
|---|
| | }); |
|---|
| | flowable.subscribe(new DebugSubscriber<>()); |
|---|
| | } |
|---|
| | |
|---|
| | public void flatmap2() { |
|---|
| | Flowable<String> flowable = Flowable.range(1, 3) |
|---|
| | .flatMap( |
|---|
| | data -> Flowable.interval(100L, TimeUnit.MILLISECONDS).take(3), |
|---|
| | (sourceData, newData) -> "[" + sourceData + "] " + newData |
|---|
| | ); |
|---|
| | flowable.subscribe(new DebugSubscriber<>()); |
|---|
| | } |
|---|
| | } |
|---|
| | |
|---|
| | |
|
