In this talk, I'm giving you 5 useful tips of RxJava you might not know. Reference - Subscriptions#empty() http://reactivex.io/RxJava/javadoc/rx/…

This article is a revision of “Testing RXJava”, completely updated to conform to the RxJava2 specification. You’ve read about RxJava; you’ve played with the samples on the internet, for example in RxJava by Example, and now you have made a commitment to explore reactive opportunities in your own code. But now you are wondering how to test out the new capabilities that you might find in your codeba

第2回スタートアップAndroid勉強会 https://connpass.com/event/48090/

In this RxAndroid tutorial for reactive programming, you will learn how to do the following: Grasp the concepts of Reactive Programming. Define an Observable. Turn asynchronous events like button taps and text field context changes into observable constructs. Transform and filter observable items. Leverage Rx threading in code execution. Combine several observables into one stream. Turn all your o

これはRxJava Advent Calendar 2016の第14日目の記事です。前回はTestSubscriberやTestSchedulerを使ってRxJavaに関わる単体テストのしかたを説明しました。 この記事では、それらでは足りない場合の奥の手、スケジューラを差し替える方法について説明します。 TestSubscriberやTestSchedulerでは解決しない場合 以下のコードを見てください。これは前回の記事で使用した AsyncService をラップした WrappedService のテストです。このラップが適切かどうかは、措いておきましょう :-) @Test public void testWrappedService() { final WrappedService service = new WrappedService(new AsyncService());

これはRxJava Advent Calendar 2016の第12日目の記事です。 RxJavaは非同期処理を扱うライブラリですが、それ故にRxJavaのからむ単体テストは一筋縄でいかないところがあります。この記事と次の記事では、RxJavaでの非同期処理テスト特有の問題と、その解決方法を説明します。なお、基本的に RxJava 1.x を対象としていますが、必要に応じて RxJava 2.x についても触れます。 この記事の続編はこちらになります。 非同期処理の単体テストの難しさ 非同期処理の単体テストは一般に難しいものです。試しに以下のコードを実行してみましょう。 @Test public void testDoSomething() { new AsyncService().doSomething() .subscribe(s -> assertEquals("success",

RxJava is used in many Android applications to manage background tasks, in this post will see how to test this code using Mockito and some RxJava utility classes. The example is written using RxJava 2, the same concepts are available also in RxJava 1 (in the demo project you can find both versions of the same example). Let’s see a simple example, we need a class (created using Retrofit) to execute

よく使うやつから絶対つかわねーだろみたいなやつ書きました。 たまーに見返して毎日をゆたかにしましょう。 もしよければこっちに基本的な使い方が書いてあるのでどうぞ 生成 create [ReactiveX - Create operator][create] 別ObservableのsubscribeによってObservalbeを生成するオペレーター。 意味が分かれば図の通りなんだけど意味わかんないと思うのでサンプルコードを。 ではどういったときに使うかというと非同期処理等でエラーハンドリングが必要な際に使います。 では具体例を。 Observable<String> observable = Observable.create( new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? su

Flux とは Facebook が提唱したアーキテクチャの名称で、最近のフロントエンド(JavaScript)界隈でアプリケーションの状態の複雑さに対応する為のアプローチの一つです。 https://facebook.github.io/flux/docs/overview.html 旧来の MVC2 もしくは Observer パターンに Action Dispatcher Sotre というコンポーネント名を定義し Flux という名称をつけたもの、と考えてもよいかと思います。 なぜフロントエンド(JavaScript)界隈で今このアーキテクチャが取り上げられているかと言うと React の仮想DOMの登場がきっかけになっています。アプリケーション開発でおおざっぱに状態(Flux でいうと Store)から View 全体を再描画するコードを書いても、仮想DOM側で差分でレンダリング

Since we started using RxJava in our Yammer Android app we’ve often encountered APIs that don’t follow its reactive model, requiring us to do some conversion work to integrate them with the rest of our RxJava Observable chains. APIs usually offer one of these two options when dealing with expensive operations: A synchronous blocking method call (expected to be called from a background thread)An as

みじかくまとめ RxJavaとAndroid Data Bindingを連携してMVVMするライブラリを作りました→RxProperty Android （2017/02/09 v3.0.0バージョンアップに伴い編集） はじめに Android標準の非同期処理の面倒さから、Android開発にRxJavaを導入する方が増えています。 実際にRxJavaを使用してみると、非同期処理のみならずイベントや各層のI/Fなど、ありとあらゆるものをストリームとして表現したくなると思います。 その結果、ストリーム末尾のsubscribeはほとんどがView操作となり、エミットされた値をセットするだけのような単純な処理を繰り返すことになります。 当然「io.reactivex.Observableに流れてきた値がそのままViewに反映されないかな」との発想が生じますが、Android Data Bindi

Ask questions, find answers and collaborate at work with Stack Overflow for Teams. Explore Teams Collectivesâ„¢ on Stack Overflow Find centralized, trusted content and collaborate around the technologies you use most. Learn more about Collectives