RxJavaを使っている既存アプリに Kotlin Coroutinesを導入しよう - Qiita
Kotlin FestのLTのネタです。(3分でどこまで話せるか謎です。) きっかけ RxJavaとCoroutinesについてJakeさんが以下のように言っていて、確かにsuspend functionのほうがわかりやすく書けると自分も感じています。 I don't use Single, Maybe, or Completable anymore since suspend functions are superior. Channels do not replace Observables. — Jake Wharton (@JakeWharton) 2018年8月3日 また既存のアプリの実装を思い浮かべたときにほとんどのRxJavaを使っているところがSingleまたはCompletableなどだったので、置き換えたほうが良さそうでは？と思いました。 個人的にはRxJavaのObs
Testing asynchronous RxJava code using Mockito
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
RxJavaがしてくれるというThread管理に、混乱したのでコードで実験 - Qiita
RxJavaを使い始めたので、書いてみました。 始まりのコード RxJavaを使えば、Threadの作成、管理をしなくてよく、お任せできるということなので便利そうなのですが、 勉強途中いったいどのThreadで何が起こっているのか分からなくなったので、書いて実験です。 まずは、 itemを3発 発射するObserableと,それに反応して処理するObserverをsubscribeします。 rxjava2でやります。 import io.reactivex.Observable; public class RxJava2 { public static void main(String[] args){ Observable.just("a","bb","ccc") .subscribe( (item)-> System.out.println("item :"+item)); } }
RxJava2 の disposable の管理をいともたやすく行うための LifecycleObserver を実装した Delegate 用クラス - Qiita
RxJava2 の disposable の管理をいともたやすく行うための LifecycleObserver を実装した Delegate 用クラスAndroidKotlinarchitecture-components RxJava での subscribe の管理ってまじ大変ですよね。CompositeDisposable を使うと思うのですが、Activityのソースがその処理ばかりになって読みづらくなりますよね。 そこで、KotlinでAndroidのRxJavaをちょっと便利に - Qiita を参考に AutoUnSubscribable を使うと思うのですが、 onResume onPause の呼び出しを忘れがちだったりしますよね。よね。 んで最近 Android Architecture Component が出てきて LifecycleObserver を使えばライフ
Kotlin の Channel と Rx の Observable/Subject の対比 - Qiita
これ の通り、Rx には本来の目的のみを遂行してもらいたいので考えみました。 まずはこれを読もう 下記に書いてある以上の説明はないです（圧倒的感謝っ） 実例によるkotlinx.coroutinesの手引き（日本語訳） - Qiita [Kotlin]コルーチンのChannelのハマり所 ｜ Developers.IO Kotlinコルーチンによるリアクティブストリームのガイド (日本語訳) - Qiita Kotlin の Channel と BroadcastChannel Channel は「キューのようなもの」と例えられます、BroadcastChannel も同じく。 Channel<T> は、送信者と受信者が 1:1 で、 BroadcastChannel<T> は、送信者と受信者が 1:n です。 Broadcast と言われるように。 両方使ってみます。 // Channe
Either で想定内のエラーと想定外のエラーを別ものにしたい！
Rx Ja Night Vol.2 (https://connpass.com/event/57150/)
Rxで非同期処理とプログレス表示切り替えを分離する - Qiita
雑記事です。 画面遷移時に画面にプログレスを表示して、データ取得待ちを表示したい SwipeRefreshLayoutで画面をリフレッシュできるようにしたい この2つを満たしつつ、2種類のプログレスの表示制御をするのがめんどくさくねというところから始まりました。 1は画面にプログレスを出したい、2はSwipeRefreshLayoutのプログレスを利用したいという感じです。 非同期処理自体は全く同じですが、トリガーが違うみたいな状態。 public class FooFragment extends Fragment { FragmentFooBinding dataBinding; @Nullable @Override public View onCreateView(LayoutInflater inflater, @Nullable ViewGroup container, @Nu
How to convert Completable to Observable? Rxjava2 - Qiita
Observableな川の流れの中で、Completableを使った時に、どうやってまたObservableとして流せばいいのか？と考えてた。 andThenというオペレータを使えばよさそう。 具体的なコードはこんな感じ Observable.just(1, 2, 3) .flatMap { number -> Completable.fromAction { showMessage("completableTest: " + number) Thread.sleep(300) }.andThen(Observable.just(number)) } .doOnNext { showMessage("doOnNext") } .doOnComplete { showMessage("doOnComplete") } .subscribe({ showMessage("onNext: " +
DataBinding + LiveData + RxJava2
これはReactiveStreamsのPublisherをLiveDataに変換したり、逆にLiveDataをReactiveStreamsに変換したりできます。 これを使うことで、RxJava2のFlowableをちょっといじるだけで、そのままDataBindingで使うことができます。 サンプルbuild.gradleimplementation "android.arch.lifecycle:extensions:1.0.0" implementation "android.arch.lifecycle:reactivestreams:1.0.0" implementation "io.reactivex.rxjava2:rxjava:2.1.7"ViewModelボタンを押すとカレントミリ秒を表示するだけです。（RxJava使う必要性はまったくないですが…）
すばやく理解する「Room x RxJava 」
いい記事があったので。 Room 🔗 RxJava – Google Developers – Medium まずは、Room で Dao. @Query(“SELECT * FROM Users WHERE id = :userId”) User getUserById(String userId); ここまでで問題なのは、 1. 同期呼び出しでブロッキング。 2. データ変更時に再度呼び出す必要がある。 ということで、RxJava を使いたくなります。 Room は RxJava2.x に対応しています。 Adding Components to your Project | Android Developers どのように使うのか? Maybe @Query(“SELECT * FROM Users WHERE id = :userId”) Maybe<User> getUserB
Room 🔗 RxJava
Doing queries in Room with RxJava Less boilerplate code, compile-time checked SQL queries, and on top of this, the power of asynchronous and observable queries — how does that sound? All of these are possible with Room, the persistence library from the Architecture Components. Async queries return LiveData or RxJava’s Maybe, Single or Flowable. The queries returning LiveData and Flowable are obser
RxJava の Observable と LiveData と ObservableField をいい感じで使おう - Qiita
LiveData について勘違いしていたことをいくつか からの続きです。 前記事では LiveData は、 購読解除を自動でやってくれるので便利 DataBinding(=ObservableField)としては使えない 最低限の合成しかできないので物足りない という事を書きました。 今回の記事では、上で挙げた微妙な３つの点を解消すべく、RxJava と LiveData と DataBinding をいい感じで併用してみたいと思います。今回もコードは Kotlin です。 RxJava with Android DataBinding RxProperty を使おう！ RxPropertyでRxJavaとAndroid Data Bindingを連携する - Qiita はい終了。 RxProperty について書くの何度目なんだ、自分。 作者の @k-kagurazaka@githu
Rxなインスタンスを返却するメソッドを実装する時の注意点 - アナログ金木犀
そういえばよくレビューで指摘してたなぁと思い出したのでメモ書き。 例えばこういうコード。 fun findContent(): Maybe<Content> { val connectivityManager = application.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager return if (connectivityManager.activeNetworkInfo.isConnected) { apiRepository.find() } else { localRepository.find() } } Content を取得したい時に、オンラインだったら apiRepository を使って、オフラインだったら localRepository を使うというコード。 このコードには
Kotlin + RxJava2 + Dagger2 + Orma + Retrofit2 で作るAndroidアプリ // Speaker Deck
All slide content and descriptions are owned by their creators.
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
How to make reusable CompositeDisposable and Kotlin extension
RxJava 2 の zip の使い方. zip の魅力にとりつかれたので RxSwift に飽き足らず RxJava… | by Naohiro Oogatta | Medium
RxJava,Kotlin,Databindingでイケてる入力フォームをスッキリ実装する – Eureka Engineering – Medium
ログイン - はてな
RxJava: as, toの違いについて - Qiita
RxJava how to group items of one list to Map<Key, List<Value>>