The Next Step for Reactive Android Programming
Download as PPTX, PDF3 likes820 views
This presentation is mainly for the participants of DevFest Berlin 2016. For the rest, a blog post is soon coming so the presentation won't be without the context. I will talk about our experience of migrating a highly reactive application, used by millions of users, from RxJava 1.x to 2.x. Firstly, I will share the advantages and disadvantages of moving to this new milestone release, so you can decide if it¡¯s worth to migrate your application. I will then focus on possible migration approaches; which strategies worked for me and which did not. Finally, we can discuss the frustrations that you need to prepare yourself for and how you can avoid them.
![Reactive Streams
compatibility
@tpolansk[1]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-3-320.jpg)
![Flux.from(Flowable.just("- I'm RxJava!"))
.map(msg -> msg + " - I'm Reactor!")
.subscribe(msg -> print(msg));
@tpolansk
RxJava 2
Reactor 3
[2]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-12-320.jpg)
![Performance
@tpolansk[3]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-26-320.jpg)
![Performance
(-76%, +2800%)
@tpolansk[3]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-27-320.jpg)
![Memory
@tpolansk[3]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-28-320.jpg)
![Memory
50% less
@tpolansk[3]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-29-320.jpg)
![Observable.just(1)
.test()
.assertValue(1)
.assertComplete();
@tpolansk
Soon in RxJava 1
[4]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-36-320.jpg)
![Bye Bye nulls
@tpolansk
¡°1B$ Mistake¡± no more
[5]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-37-320.jpg)
![10x HARDER*
@tpolansk[6]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-41-320.jpg)
![Update to
The Newest
RxJava 1.x.x
@tpolansk[7]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-63-320.jpg)
![Use
RxJava2Interop
@tpolansk[8]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-64-320.jpg)
![Replacing nulls
Null Objects
or
Optionals
@tpolansk[9]](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-82-320.jpg)
![@tpolansk
[1] Reactive Streams ¨C https://github.com/reactive-streams/reactive-streams-jvm
[2] Reactor 3 - https://github.com/reactor/reactor-core
[3] RxJava 2 Benchmark - https://github.com/akarnokd/akarnokd-misc/issues/2
[4] test() operator in v1 - https://github.com/ReactiveX/RxJava/pull/4777
[5] The Billion Dollar Mistake - https://www.infoq.com/presentations/Null-
References-The-Billion-Dollar-Mistake-Tony-Hoare
[6] Writing Operators - https://github.com/ReactiveX/RxJava/wiki/Writing-
operators-for-2.0
[7] RxJava releases - https://github.com/ReactiveX/RxJava/releases
[8] RxJava2Interop - https://github.com/akarnokd/RxJava2Interop
[9] Simple Options - https://github.com/tomaszpolanski/Options](https://image.slidesharecdn.com/thenextstepforreactiveandroidprogramming-161113064516/85/The-Next-Step-for-Reactive-Android-Programming-105-320.jpg)
More Related Content
What's hot (12)
The Next Step for Reactive Android Programming
- 1. Reactive Android: The Next Steps Futurice & upday @tpolansk Tomek Polanski
- 8. Flux.from(Flowable.just("- I'm RxJava!")) @tpolansk RxJava 2 Reactor 3
- 9. Flux.from(Flowable.just("- I'm RxJava!")) .map(msg -> msg + " - I'm Reactor!") @tpolansk RxJava 2
- 10. Flux.from(Flowable.just("- I'm RxJava!")) .map(msg -> msg + " - I'm Reactor!") @tpolansk Reactor 3 RxJava 2
- 11. Flux.from(Flowable.just("- I'm RxJava!")) .map(msg -> msg + " - I'm Reactor!") .subscribe(msg -> print(msg)); @tpolansk RxJava 2
- 12. Flux.from(Flowable.just("- I'm RxJava!")) .map(msg -> msg + " - I'm Reactor!") .subscribe(msg -> print(msg)); @tpolansk RxJava 2 Reactor 3 [2]
- 19. @tpolansk
- 23. Observable.range(0, 10) .all(it -> it % 2 == 0) @tpolansk
- 24. Observable.range(0, 10) .all(it -> it % 2 == 0) @tpolansk RxJava 1 - Observable
- 25. @tpolansk RxJava 2 - Single Observable.range(0, 10) .all(it -> it % 2 == 0)
- 37. Bye Bye nulls @tpolansk ¡°1B$ Mistake¡± no more [5]
- 39. Bye Bye nulls @tpolansk Removing takes time
- 44. @tpolansk
- 45. @tpolansk
- 52. 5600 + 9200 = 14800 @tpolansk
- 53. 5600 + 9200 = 14800 22% Dex Limit @tpolansk
- 60. Observable: 1224 int: 1516 String: 3246 @tpolansk
- 61. Observable: 1224 int: 1516 String: 3246 @tpolansk
- 62. Not in One Go! @tpolansk
- 63. Update to The Newest RxJava 1.x.x @tpolansk[7]
- 70. // Activity dataModel.getText() .subscribe(text -> view.setText(text)); @tpolansk
- 71. // Activity dataModel.getText() .subscribe(text -> view.setText(text)); @tpolansk RxJava 1
- 72. // Activity RxJavaInterop .toV2Observable(dataModel.getText()) .subscribe(text -> view.setText(text)); @tpolansk
- 73. // Activity RxJavaInterop .toV2Observable(dataModel.getText()) .subscribe(text -> view.setText(text)); @tpolansk RxJava 1
- 74. // Activity RxJavaInterop .toV2Observable(dataModel.getText()) .subscribe(text -> view.setText(text)); @tpolansk RxJava 1 RxJava 2
- 75. // DataModel Observable<String> getText() { return cache.getText(); } @tpolansk
- 76. // DataModel Observable<String> getText() { return cache.getText(); } @tpolansk RxJava 1
- 77. // DataModel Observable<String> getText() { return RxJavaInterop .toV2Observable(cache.getText()); } @tpolansk
- 78. // DataModel Observable<String> getText() { return RxJavaInterop .toV2Observable(cache.getText()); } @tpolansk RxJava 2
- 79. // Activity RxJavaInterop .toV2Observable(dataModel.getText()) .subscribe(text -> view.setText(text)); @tpolansk RxJava 2
- 80. // Activity dataModel.getText() .subscribe(text -> view.setText(text)); @tpolansk RxJava 2
- 83. class User { String name; User(String name) { this.name = name; } } @tpolansk
- 84. Observable<User> userStream = ¡ @tpolansk
- 85. Observable<User> userStream = ¡ ¡ userStream .filter(user -> user != null) @tpolansk
- 86. class User { static final User EMPTY = new User(¡°¡±); String name; public User(String name) { this.name = name; } } @tpolansk
- 87. Observable<User> userStream = ¡ ¡ userStream .filter(user -> !user.equals(User.EMPTY)) @tpolansk
- 90. NoSuchMethodError @tpolansk Wait for libs update!
- 92. @tpolansk .first(¡) .firstOrError() .singleElement() .single(¡) .singleOrError() .firstElement()
- 93. @tpolansk .first(¡) .firstOrError() .singleElement() .single(¡) .singleOrError() .firstElement() ?
- 96. TestSubscriber<Integer> ts = new TestSubscriber<>(); Observable.just(1).subscribe(ts); ts.assertValue(1); @tpolansk
- 97. TestSubscriber<Integer> ts = new TestSubscriber<>(); Observable.just(1).subscribe(ts); ts.assertValue(1); @tpolansk
- 98. TestObserver<Integer> to = new TestObserver<>(); Observable.just(1).subscribe(to); to.assertValue(1); @tpolansk
- 100. Conclusion @tpolansk
- 101. RxJava 2 Is Better! @tpolansk
- 102. New Project? Definitely RxJava 2 @tpolansk
- 103. Almost Done Project? Should Not Migrate @tpolansk
- 104. Anything Between? It¡¯s Always Up to You @tpolansk
- 105. @tpolansk [1] Reactive Streams ¨C https://github.com/reactive-streams/reactive-streams-jvm [2] Reactor 3 - https://github.com/reactor/reactor-core [3] RxJava 2 Benchmark - https://github.com/akarnokd/akarnokd-misc/issues/2 [4] test() operator in v1 - https://github.com/ReactiveX/RxJava/pull/4777 [5] The Billion Dollar Mistake - https://www.infoq.com/presentations/Null- References-The-Billion-Dollar-Mistake-Tony-Hoare [6] Writing Operators - https://github.com/ReactiveX/RxJava/wiki/Writing- operators-for-2.0 [7] RxJava releases - https://github.com/ReactiveX/RxJava/releases [8] RxJava2Interop - https://github.com/akarnokd/RxJava2Interop [9] Simple Options - https://github.com/tomaszpolanski/Options