あーるえっくす じゃばーーー Operatorの命名規則 使用できないキーワード 元のRx.NETで使ってた名前はJavaですでに使われていたのでダメだったという話 singleなアイテムを発行～完了するOperatorはReturn(T)という名前だった return(T) ⇒ just(T) そのほか…

今日もRxJava 型変換 ソースやサービスがそこで動作するフローと異なる型を返すことがある 解決手段は２通りあって 1. 目的の型へ変換する 2. 異なる型をサポートする特定の演算子を使う まぁなんかここははリファレンスを参照としか言いようがない・・・ 各…

今日もRxJavaのリファレンス読む Continuations 和訳で「継続」 Dependent 和訳で「依存」 itemが利用可能になったとき、それに依存する計算をしたい これをContinuationsと呼ぶ 最も一般的なパターンは 値を指定して別のサービスを呼び出し、結果を受け取っ…

Dependent sub-flows 和訳で「依存サブフロー」 依存サブフロー is 何 本文を読む flatMapは強力なoperatorです お、おう サンプルコード Flowable<Inventory> inventorySource = warehouse.getInventoryAsync(); inventorySource .flatMap(inventoryItem -> erp.getDem</inventory>…

Concurrency within a flow 和訳で「フローの並行性」 サンプルコード Flowable.range(1, 10) .observeOn(Schedulers.computation()) .map(v -> v * v) .blockingSubscribe(System.out::println); バックグラウンドで1～10を2乗していって、結果をメインスレ…

Javaエアプなのでちょくちょく調べないとあかん サンプルコード import io.reactivex.rxjava3.schedulers.Schedulers; Flowable.fromCallable(() -> { Thread.sleep(1000); // imitate expensive computation return "Done"; }) .subscribeOn(Schedulers.io(…

この勉強方法向いている気がした 今日もRxJavaのリファレンスを上から和訳して読んでく 用語 Upstream, downstream データフローの種類っぽい Operatorから見てどの方向にデータがストリームしているかという意味でのUp, down？ 実際に動作を確認しないとち…

ひとまずRxJavaのリファレンスを読んでみる いつもの package rxjava.examples; import io.reactivex.rxjava3.core.*; public class HelloWorld { public static void main(String[] args) { Flowable.just("Hello world").subscribe(System.out::println); …

Rxを勉強していく中で、どうせなら基礎の基礎から記事を書いていこうと思った ちょっとずつでもいいから毎日がんばろう リアクティブプログラミングはRxKotlinをちょっとかじった あとはKotlinのObservableは使ったことある程度 （RxというよりはただのObser…