Java SE 9の非同期処理ライブラリ、新概念の「Reactive Streams」を学ぶ
Java SE 9の新機能としてはあまり目立ってはいませんが、非同期処理ライブラリの「Concurrency Utilities」にも新しい機能が導入されています。Concurrency Utilitesの新機能はJEP 266 More Concurrency Updateで提案されています。導入される主な機能は以下の2つです。 Reactive Streamsの導入 CompletableFutureクラスの拡充 前者のReactive Streamsは新しい概念の導入になります。一方、後者のCompletableFutureクラスは様々なメソッドが追加されているものの、基本的な使い方はこれまでと同じです。そこで、今回は前者のReactive Streamsについて紹介していきます。 Reactive Streamsは、非同期ストリーム処理を実現するため、Reactive Stream
全て S になる -RxJava と LWS を持ち込む楽しさ-
DroidKaigi 2017 day 1, 17:10 JST
RxJava 2.0がリアクティブストリーム仕様へのサポートを含みリリースされた
RxJavaチームは18ヶ月の開発サイクルを経て彼らのリアクティブJavaフレームワークのバージョン2.0をリリースした。このリリースは重要なマイルストーンをもたらす。RxJavaはReactiveXファミリーのライブラリとフレームワークの一部である。これは彼らの言葉では"オブザーバパターンとイテレータパターン、関数型プログラミングからのもっともよいアイデアの組み合わせである"。プロジェクトの"2.0では何が違うのか"はすでにRxJava 1.xに親しんでいる開発者にとってよい手引である。 RxJava 2.0はRxJavaの真新しい実装である。このリリースはリアクティブストリーム仕様、ネットワークプロトコルと同様に実行環境(JVMとJavaScript)を対象としているノンブロッキングなバックプレッシャーで非同期のストリーム処理の標準を提供するための新提案をベースにしている。 リアクティ
Reactor Core 2.5: もう一つのJava向けReactive Extensions実装 - Qiita
Reactive Extensionの調査中にReactor Core 2.5が面白いことに気がついたのでまとめ。 JavaDoc GitHub A lite Rx API for the JVM by Sébastien Deleuze (Spring I/O 2016での発表資料) Reactor Core (2.5) = Reactive Streams + Reactive Extensions(の一部) Reactor(〜2.0)は効率的な非同期プログラミングのためのツールキットで、基本的な関数型(Java8以前に開発されたため)に始まって高効率なスケジューラー上に実装されたReactive StreamsやそのReactive Extensions(Rx)、非同期のネットワークライブラリ等を提供していました。 ところがReactor 2.5を開発するにあたってプロジェクトの構成
RxJavaの便利なOperator達 - RxJava Advent Calendar 2015 - Takuji->find;
こんにちは、RxJava歴1年くらいのtakuji31です。 これはRxJava Advent Calendar 2015、7日目の記事です。 qiita.com 6日目はk-matsさんの「何となくRxJavaを使ってるけど正直よく分かってない人が読むと良さそうな記事・基礎編」でした。 qiita.com さて、本日はRxJavaの便利なOperator達を紹介したいと思います。 cache cache operatorはemitされた値をキャッシュしておくことができるObservableを生成するoperatorです。 以下のコードは単純なループを回しつつ、標準出力にログを出すだけのObservableです。 Observable<Integer> observable = Observable.<Integer>create(subscriber -> { for (int i =
Rxjavaのcompose、あるいはRxLifeCycleについて - Qiita
TLDR composeはメソッドチェーンの中でObseravbleにアクセスできる最高のオペレーター liftとの違いはObseravbleの中の値にアクセスできるかどうか flatmapとの違いはObseravbleの中の値にアクセスできるかどうか + 実行されるタイミング RxLifecycleはtakeUntilでライフサイクルイベントをbindしてる。 RxJava Advent Calendar 5日目の今日は、composeオペレーターについて紹介します。 composeといえば、最近ではtrello/RxLifecycleでも使われているので、馴染みのある方も多いかもしれませんね。 composeは初日のエントリで紹介したliftと同じくRxJavaのメソッドチェーンを実現している要素の一つです。ではこの二つのオペレータにはどのような違いがあるのでしょうか? liftとco
OttoからRxJavaへの移行ガイド - Qiita
Otto が突然メンテナンス終了したので言われたとおりRxJavaで置き換えてみた。お、いいね、でも移行するならEventBusでいいんじゃないかな、という話 経緯 ＿人人人人人人人人人＿ ＞ 突然のdeprecate ＜ ￣Y^Y^Y^Y^Y^Y^Y^Y￣ https://github.com/square/otto/pull/181 RxJava流行っているしRxJavaで似たようなことできるからOttoのメンテナンスやめるね えー、EventBus とかOttoみたいなpub/subとRxは別物では… と思ったのだが、 gfxさんのつっこみとその後のやりとりを見て、言われたとおり参照されている記事を見てOttoを置き換えてみた Implementing an Event Bus With RxJava - RxBus 実装 OttoのかわりにRxBusというものをつくる。 RxBus
ObserverパターンとHelloWorldからはじめるRxJava - Qiita
RxJavaはObserverパターンの拡張です．ObserverパターンはGoFのデザインパターンにも登場するほど非常に一般的なものです．「オブジェクトの状態変化をそれに依存する他のオブジェクトたちが監視し，通知があったら各自が自動的に適切な振る舞いをしてほしい」というのが基本的なアイディアです．Javaではこれをinterfaceを使って実現します． 関心がある状態変化イベントをもつ対象をObservableと呼び，そのイベントを監視する対象をObserverと呼びます．java.utilパッケージにもObserverインターフェースとObservableクラスがあります． java.util.Observerインターフェースはupdate()メソッドを定義しています．状態変化を知りたい対象にはObserverインターフェースを実装してObservableに登録しておきます．そして，状
Observableでリストを得るインターフェイスの設計の具体例を少々 - Islands in the byte stream
RxJava Advent Calendar 2015の最終日です。軽めにいきます。 Observableでリストを得るインターフェイスを Observable<T> にすべきか Single<List<T>> にするべきか迷うことがあると思います。 結論からいえば、迷った時は Single<List<T>> だろうと思っています。 List<T> を得るときは、ほとんどの場合 ListAdapter などにそのまま渡すことになるでしょう。したがって、 Observable<T> インターフェイスがあっても結局 Observable#toList() で Observable<List<T>> に変換することになります。 また、典型的な二つのケース、Web API Clientを使う場合とlocal DBを使う場合を考えます。 Web API Clientの場合 Web API clien
詳解RxJava：Scheduler、非同期処理、subscribe/unsubscribe - Qiita
RxJavaで聞かれたり悩んだり、罠ったことを書き足していく予定です。 こちらもどうぞ: http://qiita.com/yuya_presto/items/152fa80d073d865cfc90 Scheduler、非同期処理 非同期でやるには？どこからが非同期で実行されるの？ Observableの実装や叩いたOperator（map()やfilter()などのメソッド）によりますが、基本的に現在のスレッド（subscribe()を呼び出したスレッド）で「同期的に」実行されます。 ドキュメントに Scheduler: This version of XXX does not operate by default on a particular Scheduler. と書かれているものは、現在のスレッドで実行されます from(): 現在のスレッドで実行されます Subject: o
Java 8: No more loopsをRxJavaでやる(Androidの環境で) - visible true
Java 8: No more loops Java8のStream APIを使ってforループを無くすという記事。面白そうだったのでRxJava化しました。AndroidだとJava8 Stream API使えないですからね (´･ω･`)。Java8世界ではRxJavaってどういう位置づけなんでしょう気になります。 元記事と同じ様に、forループのあるコードとRxJavaでのコードを並べる形にします。Articleクラスについてはコチラには記載しないので元記事を見て下さい。シンプルなモデルなので見るまでもないかもしれません。 AndroidでのJava8環境構築は、 RxAndroidとRetrolambdaで大体Java8をAndroidに持ち込む - visible true を参照して下さい。 getFirstJavaArticle() タグにJavaを含む最初のArticleを
neue cc - RxJava Night振り返り（Reactive Extensionsの歴史）
RxJava Nightというイベントで、Rxの歴史！というほど大仰なものでもないですが、誕生から今に至るまでをサラッと振り返った資料でLTしてきました。 普段は時間オーバー常習犯なんですが、今回はちゃんと時間を意識して収めましたよ！中身的にはまだまだアレもコレも詰めたい欲もあったりなかったりですが、まぁむしろこのぐらいが丁度良いのかもしれません。幸い、わりかし評判も良かったようで何よりです。 Rx across languages 改めて実感したのは、もうRxは.NETだけのものじゃない、ということです。むしろ他言語のほうがずっと盛り上がっているというのは実感するところで、ReactiveCocoa、そしてRxJava。こちらのほうが熱い。それはもう事実として。勿論いいことです。とはいえそうなると、もはや.NETのReactive Extensionsの存在すら知らない人も沢山いるという
RxJava的なものを最小限に実装してコンポーネントの関係を理解する - Qiita
社内のRxJava勉強会用の資料です。 軽く、ほんの軽くRxJavaのサブセットを20行ほどで実装してみました。 https://github.com/gfx/RxInTheBox 概要 RxJavaはPromise的なもので、連続した「イベントの発生 / 値の生成」を扱えるようにしたもの Observableは「イベントが発生するかもしれない状態 / 値の生成中」という状態を表すオブジェクト OnSubscribeはObservableの中身で、「イベントの発生 / 値の生成」をObservableに通知するためのオブジェクト SubscriberはObservableから「発生したイベント / 生成された値」を受け取るコールバック RxJavaの捉え方 まずRxJavaですが、いくつかの捉え方があります。 リスト処理の抽象化・ストリーム化 Optional的な何か Promise的な何
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Pitfalls of operator implementations (part 1)
Functional Reactive Programming with RxJava - JavaOne 2013
The new Completable API (part 2 - final)
The new Completable API (part 1)
GitHub - android10/frodo: Android Library for Logging RxJava Observables and Subscribers.
Gradle で RxJava を動かす - Qiita
Reactive とは何か？ #reactive_shinjuku
