RxJava

Size: px

Start display at page:

Download "RxJava"

吟剩夏
6 years ago
Views:

1 RxJava By 侦跃头 hi

2 RxJava 扩展的观察者模式处

3 观察者模式 Observable 发出事件 Subscriber 订阅事件

4 bus.post(new public void onanswer(answerevent event) {! }!

5 Observable observable = Observable.create(new Observable.OnSubscribe<String>() public void call(subscriber<? super String> subscriber) { subscriber.onnext("a"); subscriber.oncompleted(); } }); observable.subscribe(new Subscriber() { });

6 观察者模式的不足时结错误

7 RxJava 进 oncomplete Subscriber 结 onerror Subscriber 错

8 Observable.just("hello").subscribe(new Subscriber<String>() public void oncompleted() { public void onerror(throwable e) { public void onnext(string s) { System.out.println(s); } });

9 unsubscribe Subscription subscription = observable.subscribe(system.out::println); subscription.unsubscribe();

10 处观产线订阅线处

11 Observable.just("hello") // 观线产.subscribeOn(Schedulers.newThread()) // 观 UI 线.observeOn(AndroidSchedulers.mainThread()) // 为 UI 线程接收数据, // 这 UI.subscribe(System.out::println);

12 Scheduler 认 RxJava 产订阅线运! Scheduler 换产订阅执线! RxJava 认 Scheduler 针对务选择

13 Schedulers Schedulers.immediate() Schedulers.trampoline() Schedulers.newThread() Schedulers.computation() Schedulers.io() AndroidSchedulers.mainThread()

14 处 -Operator 对进变换处 operators 义 operator

15 Observable.just(1, 2, 3).map(new Func1<Integer, String>() public String call(integer integer) { return integer.tostring(); } }).subscribe(new Action1<String>() public void call(string s) { System.out.println(s); } }); Observable.just(1, 2, 3).map(integer -> integer.tostring()).subscribe(system.out::println);

16 务组组转换过滤掉小于 1

17 Observable.just("1", "2", "2", "3", "4", "5").map(Integer::parseInt).filter(s -> s > 1).distinct().take(3).reduce((integer, integer2) -> integer.intvalue() + integer2.intvalue( ).subscribe(system.out::println);//9

18 operators 创建 Observable create just 变换 Observable map flatmap 过滤 Observable filter first last Observable merge zip 错误处理 catch 过滤 all skiputil takewhile average reduce count

19 义 operator Observable.just( a ).lift(subscriber -> { return new Subscriber<String>() public void oncompleted() { subscriber.oncompleted(); public void onerror(throwable e) { subscriber.onerror(e); public void onnext(string s) { subscriber.onnext(1); } }; }).map(i -> i).subscribe(system.out::println);//1

20 Android 应 Retrofit RxAndroid RxBinding rx-preferences sqlbrite RxLifecycle

21 Observable<NewsDetail> long id);

22 RxAndroid AndroidSchedulers.mainThread()

23 RxBinding RxJava 对 Android UI 进

24 RxView.clicks(findViewById(R.id.btn_throttle)).throttleFirst(1, TimeUnit.SECONDS).subscribe(aVoid -> { System.out.println("click"); });

25 RxPreference RxJava SharePreference

26 SharedPreferences preferences = PreferenceManager.getDefaultSharedPreferences(context);! RxSharedPreferences rxpreferences = RxSharedPreferences.create(preferences);! Preference<String> username = rxpreferences.getstring( username");! username.asobservable().subscribe(new Action1<String>() public void call(string username) { Log.d(TAG, "Username: " + username); } }

27 RxBinding 结合 RxPreference SharedPreferences preferences = PreferenceManager.getDefaultSharedPreferences(this); RxSharedPreferences rxpreferences = RxSharedPreferences.create(preferences); Preference<Boolean> checked = rxpreferences.getboolean("checked", true); CheckBox checkbox = (CheckBox) findviewbyid(r.id.cb_test); RxCompoundButton.checkedChanges(checkBox).subscribe(checked.asAction()); checked.asobservable().subscribe(aboolean -> { System.out.println(" checked: " + aboolean); });

28 RxLifecycle Activity Fragment 结

29 myobservable.compose(rxlifecycle.binduntilactivityevent(lifecycle, ActivityEvent.DESTROY)).subscribe(); myobservable.compose(rxlifecycle.bindactivity(lifecycle)).subscribe();

30 RxJava 场现层调 (Callback hell) 杂处应 UI 杂线换

31 层调 gettoken(new Callback<String>() public void success(string token) { getuser(userid, new Callback<User>() public void success(user user) { userview.setuser(user); public void failure(retrofiterror error) { // Error handling } }; public void failure(retrofiterror error) { // Error handling } });

32 gettoken("username", "password").flatmap(token -> getuser(token)).subscribe(user -> { System.out.println("user: " + user.tojson()); });

33 杂处 Observable.just("1", "2", "2", "3", "4", "5").map(Integer::parseInt).filter(s -> s > 1).distinct().take(3).reduce((integer, integer2) -> integer.intvalue() + integer2.intvalue()).subscribe(system.out::println);//9

34 应 UI CheckBox checkbox = (CheckBox) findviewbyid(r.id.cb_test); RxCompoundButton.checkedChanges(checkBox).subscribe(checked.asAction());

35 杂线换 Observable<String> observable1 = createobservable1().subscribeon(schedulers.newthread()); Observable<String> observable2 = createobservable2().subscribeon(schedulers.io()); Observable.concat(observable1, observable2).subscribeon(schedulers.computation()).subscribe(system.out::println);

36 RxJava 库体积稍大 (900K 对时 unsubscr RxBinding 库 ) Java6 lambda 简化代码 (Retrolambda & Gr

37 扔物线的 : 给 Android 发 RxJava 详解 560e15be2dca930e00da1083 RxJava lzyzsd/article/details/

38 应用案例 Square SoundCloud Flipboard 动

39 Thanks

40 Q&A

教学〔2016〕120号

教学〔2016〕120号河南省教育厅教学 2016 120 号河南省教育厅关于对口招收中等职业学校毕业生进入普通高等学校学习的通知各省辖市省直管县 ( 市 ) 教育局, 省各级招生机构, 各普通高等学校省属中等职业学校 : 为贯彻党的十八大和十八届三中四