RxIo map 操作符
map 变换操作符负责数据变换操作,将一个数据类型转换成另外一个数据类型,用事件图表示如下:
代码示例
@Test
public void testRxIoMap() throws Exception {
RxIo.from(1, 2, 3)
.map(new IoFunction<Integer, String>() {
@Override
public String call(Integer t) {
return "AA:" + t;
}
}).subscribe(new IoSubscriber<String>() {
@Override
public void onNext(String value) {
System.out.println(value);
}
@Override
public void onCompleted() {
System.out.println("execute complete");
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
}).start();
}