RxJava 源码解读分析 map
2017-05-08 11:33
316 查看
我们来看盾RxJava Observable.map方法,先上一段示例代码:
@Test
public void test() throws InterruptedException {
Observable.create((Subscriber<? super Integer> subscriber)->{
log.debug("Observable, hello, rxjava");
subscriber.onNext(1);
subscriber.onNext(2);
subscriber.onNext(3);
subscriber.onCompleted();
}).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
return integer + "INT";
}
}).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
log.debug("Subscriber1, onCompleted event");
}
@Override
public void onError(Throwable throwable) {
log.error("Subscriber1, onError event", throwable);
}
@Override
public void onNext(String v) {
log.debug("Subscriber1, onNext event, value={}", v);
}
});
Thread.sleep(1000*2);
}我们再来看看map方法都做了做么,如下图:
注意再圈的三个地方,map的参数是一个Func1类,Func1类有两个泛型,T和R,T代码输入参数类型,R代表输出结果类型,map方法的返回值还是一个Observable,但其泛型的类型变了,变成了R,所以后面的subscriber能接受的泛型也是R类型的。
我们接下来看看OnSubscribeMap这个类,如下图:
在OnSubscribeMap.call方法内,创建了一个MapSubscriber类,重点看这个类的onNext方法,先调用Func1.call方法进行类型转换,再调用actual.onNext()方法,actual就是原始的subscriber。
由此可以看出,map()方法很简单,就是调用func1进行类型转换,再调用subscriber的onNext()进行处理。
@Test
public void test() throws InterruptedException {
Observable.create((Subscriber<? super Integer> subscriber)->{
log.debug("Observable, hello, rxjava");
subscriber.onNext(1);
subscriber.onNext(2);
subscriber.onNext(3);
subscriber.onCompleted();
}).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {
return integer + "INT";
}
}).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
log.debug("Subscriber1, onCompleted event");
}
@Override
public void onError(Throwable throwable) {
log.error("Subscriber1, onError event", throwable);
}
@Override
public void onNext(String v) {
log.debug("Subscriber1, onNext event, value={}", v);
}
});
Thread.sleep(1000*2);
}我们再来看看map方法都做了做么,如下图:
注意再圈的三个地方,map的参数是一个Func1类,Func1类有两个泛型,T和R,T代码输入参数类型,R代表输出结果类型,map方法的返回值还是一个Observable,但其泛型的类型变了,变成了R,所以后面的subscriber能接受的泛型也是R类型的。
我们接下来看看OnSubscribeMap这个类,如下图:
在OnSubscribeMap.call方法内,创建了一个MapSubscriber类,重点看这个类的onNext方法,先调用Func1.call方法进行类型转换,再调用actual.onNext()方法,actual就是原始的subscriber。
由此可以看出,map()方法很简单,就是调用func1进行类型转换,再调用subscriber的onNext()进行处理。
相关文章推荐
- [RxJava学习]操作符Map源码分析
- RxJava进阶之源码分析map() 操作符分析
- Rxjava_自己实现Rxjava map转换及源码分析
- RxJava 源码解读分析 subscribeOn 方法
- 对Rxjava1.0的map方法的源码分析
- RxJava 源码解读分析 observeOn
- RxJava 源码解读分析 just
- RxJava 源码解读分析 观察者模式
- RxJava 源码解读分析 defer
- RxJava 源码解读分析 Scheduler
- RxJava 源码解读分析 from
- RxJava 源码解读分析 flatMap
- [RxJava学习]操作符flatMap源码分析
- RxJava1.0 flatMap方法的源码分析
- HashSet源码分析解读
- Mybatis_源码分析_参数封装Map过程
- RxJava2_map操作符源码解析
- netty源码分析(十三)Netty核心四大组件关系与构建方式深度解读
- java ConcurrentSkipListMap原理分析及源码解析
- JVM源码分析之javaagent原理完全解读