Observable#createは今後使わないほうがいいかもしれない - Qiita
若干の釣り気味ですが、RxJavaを利用されている方には結構重要そうだよな−と思う話題だったのでQiitaにまとめました。 ことのはじまり Check out the new fromAsync() operator for adapting callback-based sources into Observables. Stop using create()! https://t.co/3SvYMmgeWx — Jake Wharton (@JakeWharton) 2016年7月10日 なんだかJakeが過激なこと言ってる気配があったので、背景を調べるために少しissueを漁り始めました。 きっかけのissue https://github.com/ReactiveX/RxJava/issues/4177 すごく雑に3行でまとめると、 非Rxの世界の非同期処理をラップするのにObse
The new Completable API (part 1)
Programming deep-dive into RxJava, Reactive-Streams, Project Reactor and Java 9 Flow. Introduction If you are following the day-to-day RxJava GitHub activity, you might have noticed a PR about a new and mysterious rx.Completable class. This PR has been merged into the 1.x branch (in @Experimental fashion) and will most likely be part of RxJava 1.1.1. In this two part series, I'm first going to int
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
Implementing an Event Bus with RxJava - RxBus - Wedding Party
This post has three parts: quick primer on what an event bus is implementing the event bus with RxJava parting thoughts on this approach “RxBus” is not going to be a library. Implementing an event bus with RxJava is so ridiculously easy that it doesn’t warrant the bloat of an independent library. Part 1: What is an event bus? Let’s talk about two concepts that seem similar: the Observer pattern an
RxJava (+RxAndroid) で認証つきのリクエストのちょっと複雑なエラーハンドリングをする - Qiita
Retrofit + RxJava (+RxAndroid) で以下のようなちょっと複雑なユースケースはどう書けばよいのかなと調べてみたら defer と onErrorResumeNext を使えばよいんじゃないか、という話 (ただしRetrofitは関係ない話になった)。 参考: retrofit with rxjava handling network exceptions globally ユースケース ユーザ情報を取得するAPIを叩く（認証が必要なAPI） 401が返ってきたら、アクセストークンを再度取得する処理を行う アクセストークンの再取得に成功した場合は、新しいアクセストークンを使って、もとのリクエスト（ユーザ情報の取得）をもう1回行う アクセストークンの再取得に失敗した場合は、ログイン画面に飛ばす 実装 private void getUser() { Observabl
RxJava は Subscriber を中心に捉えると理解しやすいんじゃないかという話 - hydrakecat’s blog
これは RxJava Advent Calendar 2015 の第22日目の記事です。昨日は kazy さんによる RxJava 2.xについて でした。 この記事では、 RxJava を理解するために自分が RxJava をどのように捉えているか、という話をします。なお、自分は ReactiveX や Reactive Functional Programming について詳しいわけではないので、その方面の理解の助けになるものではありません。どちらかといえば、RxJava という特定のライブラリをこう理解しておけば全体の挙動を把握しやすいのではないか、という生活の知恵のようなものになります。RxJS や他のライブラリではまた異なる実装かもしれませんのでご留意ください。 RxJava は非常に強力でよく考えられたものですが、ソースを見て挙動が直感的に分かるとは言えないライブラリです。本稿
Realm Java 0.87 — with RxJava support!
We just released a new version of Realm Java to this website and to Maven. This release includes first-class API support for RxJava. RxJava RxJava is a Reactive Extensions library from Netflix that extends the Observer pattern. It makes it possible to work with changes to Realm data using composable sequences of operators. All Realm classes except RealmQuery and RealmList can now be exposed as an
RxJava - Hot Observable と ConnectableObservable について - Qiita
空いてたので参加してみました。 普段は Xamarin(C#) + Reactive Extensions + ReactiveProperty で、Reactive + MVVM な Android/iOS両対応アプリを開発しています。 Cold vs Hot Cold Observable は「あなただけの」Stream、Hot は「みんなの」Stream 。 （私的にはニコ動かニコ生か、みたいに理解してますが、その話はいいや） Cold は、あなたが subscribe した瞬間からデータが流れ始めます。 Hot は、あなたが subscribe してもデータは流れ始めません(流れるかも知れません？)。 では Hot Observable はいつからデータが流れ始める？Observable が生成された瞬間から？ その答え(の一つ)が ConnectableObservable 。
Rxで知っておくと便利なSubjectたち - Qiita
この記事はRxJava Advent Calendar 2015 11日目の記事です。 RxJava・RxAndroidの紹介記事の中にはよく「面倒くさいASyncTaskを使わなくて済む」といったRxJavaを非同期処理の代わりとして紹介されています。 もちろん、非同期処理を置き換えられるという点はRxJavaの有効的な使い方の一つですが、RxJavaには他にも便利に使える機能があります。 今回はそれらの機能の一つであるSubjectについて紹介したいと思います。 Subjectとは 短く言うと「SubscriberとObservableの2つの機能を併せ持ったもの」です。 SubscriberにあるようなonNextやonError、onCompleteといったメソッドを呼び出せ、Observableのようにsubscribeメソッドを呼び出すことができます。 Subject<Stri
How to upgrade to RxAndroid 1.0
A number of people have asked me recently, "What the hell happened to RxAndroid?" The fact of the matter is, RxAndroid was getting to be a bit of a mess and thus has been majorly refactored. You can read more about it here, but essentially: I am proposing a from-scratch, modularization of the library into re-usable and composeable modules. That has been accomplished, but if you upgrade now you're
イベントバスとリアクティブプログラミングの違いについて - torutkのブログ
GUIを持つアプリケーションの設計では、ソフトウェアアーキテクチャパターン*1としてMVCパターンを使用し、MVCパターンを実現する上で、Modelの変更をViewやControllerへ通知する仕組みにデザインパターン*2としてObserverパターンを使用するのが古典的定番です。 ところが、Observerパターンを使ったModelには、Observableのリストを管理し、状態変更の際にリストに登録されるObserbable全てに通知する仕組みを実装する必要があり、結構な作業となります*3。 このModelからの通知をObserverパターンで実現する代わりに、イベントバスを使って実現すると、Modelの実装を簡潔にすることができます。Java SEではあまり事例を見かけませんが、Androidでは割とメジャーに使われているようです。 先日、Androidでイベントバスのライブラリを
RxJava を使って、非同期通信処理とテストを書いてみた | rakuishi.com
例えば、ある通信処理で得られるトークンをもとに、次の通信処理を行うケースを考えてみる。Android アプリでは、同期的な通信は許可されていないから、非同期処理を続けて書く必要になりそうだ。これを愚直に実装すると面倒なことになりそうだが、RxJava で解消しそうだった。 RxJava とは、 リアクティブプログラミングを可能にするライブラリである（知らない言葉を説明するために、知らない言葉が登場してくる）。リアクティブプログラミングについては詳しくないのですが、このライブラリを使えば前述のようなプログラムが可読性高く書けるようになるようだった。 マテリアルデザインを用いたデザインリニューアル [フリル編] 65 スライド目 この RxJava を使って、非同期通信処理とテストを書いてみた。 非同期通信処理 今書いている Android アプリ rakuishi/OK の通信処理（このブロ
Unit Testing RxJava Observables
At ribot, we started using RxJava a few months ago and now it’s become a core element in the architecture of the Android apps we create. There are many benefits that come with it, but the learning curve is steep and quite often we still find ourselves trying to get our heads around those “beautiful” diagrams that explain how operators work. The first step to rx-ify our architecture was to change t
RxJavaについて調べた試した - みんからきりまで
RxJava Nightに向けてRxJavaについて調べ始めたものの、日本語の情報がほとんど無くて辛かったので調べた事をまとめました。 RxJavaやリアクティブプログラミングについては今までまったく知らなかったので、内容には間違いが含まれている可能性があります。予めご容赦頂いた上でご覧ください。 元ネタはほぼ ReactiveX/RxJava/Wiki Grokking RxJava 【翻訳】あなたが求めていたリアクティブプログラミング入門 - ninjinkun's diary です。 RxJavaとは RxJavaとはリアクティブプログラミングを行うためのライブラリであるRx(Reactive Extensions)のJVM版とのこと。 リアクティブプログラミングの概念についてはそれほどよく理解出来ていないので、上記の記事などを参照してください。 StreamAPI＋非同期コールバッ
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
明日から使えるRxJava頻出パターン
rxjava_modules
Rx逆引き
Cached rest requests with rxjava
年末だしお掃除をしよう！
Rxjavaとoptionalで関数型androidしよう
