在初步应用RxJava时发现，网上资料中Observable的创建例子主要使用create/just/from，都是将现在已有的数据序列整理为一个发射器，而我们最常见的应用却是现在没有数据序列，等待将来数据序列的到达，比如等待用户点击或输入，或等待网络来包，也即，我们其实需要一种手动的发射器，在数据到达后用来发送这些数据。那么怎样创建这种发射器呢？查询资料后发现有几个途径，下面用点击textview来示例。
第一类，使用RxBinding提供的RxView等直接封装输入控件，这是特别为Android定制的，自然也是最简单方便的：
private void rxview_click() { RxView.clicks(textView).subscribe(new Consumer<Object>() { @Override public void accept(Object o){ append_str(" "+((int) (Math.random() * 10))); } }); } 第二类，使用Observable.create (new ObservableOnSubscribe ()) 来获取一个 emitter 发射器，并将这个发射器挂入 textview 的点击监听事件中，这样 textview 被点击时触发这个 emitter 发射器就可以了： private void observable_emitter() { Observable.create(new ObservableOnSubscribe<Integer>() { @Override public void subscribe(@NonNull final ObservableEmitter<Integer> e) throws Exception { e.setCancellable(new Cancellable() { //when emitter send cancel, textview remove listener? @Override public void cancel() throws Exception { textView.setOnClickListener(null); } }); textView.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { e.onNext((int) (Math.random() * 10)); } }); } }).subscribe(new Consumer<Integer>() { @Override public void accept(@NonNull Integer integer) throws Exception { append_str(" " + integer); } }); }使用Flowable来替代Observable也是一样的：
private void flowable_emitter() { Flowable.create(new FlowableOnSubscribe<Integer>() { @Override public void subscribe(@NonNull final FlowableEmitter<Integer> e) throws Exception { textView.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { e.onNext((int) (Math.random() * 10)); } }); } }, BackpressureStrategy.MISSING).subscribe(new Consumer<Integer>() { @Override public void accept(@NonNull Integer integer) throws Exception { append_str(" " + integer); } }); } 第三类，也非常的简单清晰的，使用 PushlishSubject ： private void publish_subject() { final PublishSubject<Integer> publishSubject = PublishSubject.create(); publishSubject.subscribe(new Consumer<Integer>() { @Override public void accept(@NonNull Integer integer) throws Exception { append_str(" " + integer); } }); textView.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { publishSubject.onNext((int) (Math.random() * 10)); } }); } 推荐一篇关于 publishSubject 的极简明清晰解释： https://blog.mindorks.com/understanding-rxjava-subject-publish-replay-behavior-and-async-subject-224d663d452f上面所有例子的完整可以运行代码放在：https://github.com/maxyou/PublishSubjectDemo
