create操作符
2016-05-28 18:39
281 查看
写在最前:所有的Observer和Observable都是通过OnSubscribe建立关系的(此关系叫做Subscription),不管是哪一个操作符,必定都有一个与其相关的OnSubscribe;
Create操作符
1. 作用
创建一个简单的Observable对象,当observer订阅到此Observable时产生订阅关系,该订阅关系又Subscription对象管理(即取消订阅)。当Observer和Observable之间产生订阅关系时,OnSubscribe对象的call方法被回调执行一些操作,在call方法结束之前需要显示调用subscriber.next()和subscriber.complete()。如果在call方法执行时产生异常,则subscriber的onError方法被回调来通知用户。2. 用法
observable = Observable.create(new OnSubscribe<Integer>(){ public void call(Subscriber<? super Integer> subscriber){ //Do Something //必须在此显式调用 subscriber.next(1); subscriber.complete(); } }); Subscription subscription = observable.subscribe(new Observer<Integer>(){ @Override public void onCompleted() { System.out.println("Complete"); } @Override public void onError(Throwable e) { System.out.println("e = [" + e + "]"); } @Override public void onNext(Integer s) { System.out.println("s = [" + s + "sss" + "]"); } });
3. 事件流分析
整个事件流执行过程如下:observalbe.subscribe(observer); //产生订阅关系 observalbe.subscribe((Subscriber)observer); //将Observer包装为Subscriber observalbe.subcribe(subscriber, observable); //将Observable和subscriber subscriber.onStart(); //做一些初始化工作 //在这儿还需要将subscriber包装为SafeSubscriber onSubscribe.call(); //调用call方法。
相关文章推荐
- sql2005 附加数据库出错(错误号:5123)解决方法
- sql2005 create file遇到操作系统错误5拒绝访问 错误1802
- MySQL里Create Index 能否创建主键 Primary Key
- 在数据库‘master’中拒绝CREATE DATABASE权限问题的解决方法
- 解决MYSQL出现Can''t create/write to file ''#sql_5c0_0.MYD''的问题
- CREATE FUNCTION sqlserver用户定义函数
- thinkPHP中create方法与令牌验证实例浅析
- ThinkPHP中的create方法与自动令牌验证实例教程
- ThinkPHP表单数据智能写入create方法实例分析
- mysql 下载及安装方法
- 跟我一起看Retrofit 2.0的源码
- RxJava之subscribeOn解惑
- PHP使用stream_context_create()模拟POST/GET请求的方法
- GP数据库关于行列转换
- Create a TestDisk FreeDos LiveCD
- mysql 数据库更改引擎
- How To Create a SSL Certificate on Apache for Debian 8 htttps
- How To Create a SSL Certificate on Apache for Debian 7 |htttps
- zabbix安装配置