Tag: 事件

从普通的Java事件创建Observable

从古典Java事件模式创建Rx-Java Observable的最佳方式是什么？ 那就是给定的 class FooEvent { … } interface FooListener { void fooHappened(FooEvent arg); } class Bar { public void addFooListener(FooListener l); public void removeFooListener(FooListener l); } 我想实现 Observable<FooEvent> fooEvents(Bar bar); 我想到的实现是： Observable<FooEvent> fooEvents(Bar bar) { return Observable.create(new OnSubscribeFunc<FooEvent>() { public Subscription onSubscribe(Observer<? super FooEvent> obs) { FooListener l = new FooListener() { public void […]