Angular + RxJS + WebSocket で チャットアプリを作る – Subject 利用サンプル | DevelopersIO
以前、別の記事でAkka製のチャットサーバを作ったのでシンプルなクライアントアプリも作りました。 バージョン情報 パッケージ名 バージョン WebSocketとSubjectの連携イメージ RxJSの部品は、今回 Subject を使います。Subjectは、定義したバックエンドのデータソースを Subscribe することができ、なおかつバックエンドに対して next によりデータを送出する能力をもっています。一方でWebSocketはコネクションが成立した後、 onmessage イベントに対するハンドラを登録してデータ受信時のアクションを定め、 send によってデータを送信します。この時点で Subject と WebSocketは相性が良いのではないかと考えました。実際この考えを実装した先人がいます。 WebSockets with Angular2 and RxJS – Łuk
RxJava2.0 Observable, Single, Maybe, Completableの使い分けメモ - Qiita
概要 RxJava2.0でObservableに似たFlowableやMaybeが追加されました。 またSingleやCompletableも以前から存在します。 つまりObservable, Flowable, Single, Maybe, Completableが存在します。 これらはObservableのように、item(Javaのインスタンスなど)をemit(排出)します。 使い分けを行うことで、使う側のObserver(Subscriber)で考えることを減らすことができます。 それぞれどのような特徴があり、どのように使い分けるかを見ていきます。 FlowableはBackpressureに関するもので少しジャンルが違うので省略しています。(正直自分がBackpressureが必要になるほど使いこなせていないです。。) 何か誤りなどございましたらご指摘お願いします。(編集リクエス
Android で RxJava を利用して Flux してみた - Qiita
Deleted articles cannot be recovered. Draft of this article would be also deleted. Are you sure you want to delete this article? Flux とは Facebook が提唱したアーキテクチャの名称で、最近のフロントエンド(JavaScript)界隈でアプリケーションの状態の複雑さに対応する為のアプローチの一つです。 https://facebook.github.io/flux/docs/overview.html 旧来の MVC2 もしくは Observer パターンに Action Dispatcher Sotre というコンポーネント名を定義し Flux という名称をつけたもの、と考えてもよいかと思います。 なぜフロントエンド(JavaScript)界隈で今こ
RxJavaのレシピ：Androidのイベントをストリームに変換する | POSTD
問題 まず、これから解決していく問題を先に述べます。 イベント（例えばOSの通知やBluetoothの状態）を受け取る部分がアプリ内に複数あり、各部分に関係がある時にのみその情報を受け取りたい場合を想像してみてください。 アプリの最初のクライアントが関心を持った時にのみイベントリスナーが登録され、誰も関心を持たなくなれば、すぐに登録を解除する必要がある。 新しいクライアントがイベントを購読する際、既存のクライアントに送信済みの前回のイベントを新しいクライアントがすぐに受け取れるようにして、全クライアントが常に同期するようにする。 今回の記事では、RxJavaの様々なコンポーネントを組み合わせることで、この問題を解決する道を探ろうと思います。本題に入る前に、 Subject や Replay 、そして Connectable Observables などのコンセプトを理解しておいてください。
Android data bindingを使ってMVVMなアプリを書く - Qiita
Deleted articles cannot be recovered. Draft of this article would be also deleted. Are you sure you want to delete this article? data bindingちゃんと触ったことがなかったので、data bindingを使ったMVVMなアプリを書いてみました。 機能を限定したGitHubクライアントです。よくあるTODOアプリみたいなシンプルなものだと実戦投入したときの詰まりどころがよくわからない気がしたので、以下のような画面を含むそこそこ複雑なアプリにしてみました。 リポジトリの一覧画面と詳細画面があり、それぞれでスターできる。各画面でのスター操作の結果は同期している。 リストビューでサーバーから取得したリポジトリ一覧を表示する。一度取得したリストはSQLiteにキャ
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 は非常に強力でよく考えられたものですが、ソースを見て挙動が直感的に分かるとは言えないライブラリです。本稿
ユースケースで入門するAndroid RxJava1 - Qiita
RxJavaの入門記事でリスト操作や非同期処理が楽になるってのはわかったんだけど、それだけだとイマイチRxJavaの凄さが伝わってこないなぁという人向け Observableってなんだって人はまずはこちらを一読するといいかもしれません。 みんからきりまで - RxAndroidをカジュアルに使ってみるとか Observableを合成して複雑なイベント処理を簡潔にする的なユースケースを紹介します。 RxJava以外にRetrofit, RxBinding, RxAndroidというライブラリもつかってますが、特に気にしなくて大丈夫でしょう。 複数APIリクエスト 複数のAPI待ち合わせ 2つのAPIからStringを取得して、レスポンスが揃ったらそれぞれをTextViewに表示してみましょう。 Observable.zip(fooClient.fetch(), barClient.fetch
詳解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
Androidビルディングデザイン - TechBooster - BOOTH
2015/8/24 電子書籍（PDF版）を登録しました。 紙面をPCやタブレット用に最適化しています（本文サンプルの1枚目を参照ください）。 Androidビルディングデザイン（156p）は、設計方針をたてるのに大変便利な一冊です！ 注目のData Binding、非同期プログラミングのためのRxJava、Javaを改善するプログラミング言語Kotlinの3つのライブラリを解説します。 また今後のAndroidを語る上で避けられないトピックとしてマテリアルデザイン対応アイコンの作り方、Android Mの新パーミッションモデル、プッシュサービス、ProjectTangoなど最新情報を集めました。 詳細な目次、本文はサンプルでご確認ください 目次 第1章 Introduction to RxJava @__gfx__ 第2章 Fundamental Of The Data Binding @
イベントバスとリアクティブプログラミングの違いについて - torutkのブログ
GUIを持つアプリケーションの設計では、ソフトウェアアーキテクチャパターン*1としてMVCパターンを使用し、MVCパターンを実現する上で、Modelの変更をViewやControllerへ通知する仕組みにデザインパターン*2としてObserverパターンを使用するのが古典的定番です。 ところが、Observerパターンを使ったModelには、Observableのリストを管理し、状態変更の際にリストに登録されるObserbable全てに通知する仕組みを実装する必要があり、結構な作業となります*3。 このModelからの通知をObserverパターンで実現する代わりに、イベントバスを使って実現すると、Modelの実装を簡潔にすることができます。Java SEではあまり事例を見かけませんが、Androidでは割とメジャーに使われているようです。 先日、Androidでイベントバスのライブラリを
RxJavaに3日で入門し、Androidアプリのリスト操作、非同期処理、変更通知の課題を解決した話 - Qiita
なんでこの記事書いたのか 今開発中のプロダクトにおいて、RxJavaの導入をやってみたので、実際に使った箇所とその例、調べないとわからなかったことを載せておきました。 そう（retrolambdaのためにjdk8を投入）までして導入したかったメリットを話してくれ、サンプルコードがないとわからん、といった声を頂いているので、実際に何が解決されたのか、どんなコードで解決したのかということと、そのために勉強しなくてはならなかった点について書いています。 （追記）警告：差分作ってコード上では解決したんですが、この差分まだ「リリース」したわけじゃないので、その点だけご注意くださいｍｍ 続報あり次第追記します。 追記：リリースして安定運用しています！最近まで監視に難がありましたがそれも修正しました。この記事の監視スニペットも更新済みです！ なぜRxJavaを導入したのか 次の課題をまとめて解決できるの
Android開発でRxJavaをチームに導入した話 - クックパッド開発者ブログ
買物情報事業部の八木(@sys1yagi)です。 Android界隈でRxJavaが話題になっていますね。クックパッドアプリ(以後、「本体」と表現します)でも先日ついにRxJavaの導入を果たしました。本エントリではRxJavaをチームに導入する為に行ったいくつかの取り組みを紹介します。 目次 RxJava導入の失敗 どのような課題を解決するのか 導入の為に機能を分解し、学習コストを考える ブログを書く 低コスト、低リスクに導入する 勉強会を開く RxJava導入の失敗 2014年11月にRxJavaの1.0.0がリリースされました。遂に実用段階かという事で個人的にあれこれ触り、本体に導入する機会を伺っていました。ある日、bug fixの為にRxJavaを使うと簡潔になるのではないかと思い気軽にPull Request(以後、PRとします)を送った所、「このタイミングで急に導入する意図はな
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
初心者のための RxJava
Hi, I'm ogaclejapan
RxAndroidを使ってInapp Billing v3 を試す - Qiita
RxJava on Android
分かった気になるはじめてのRxJava
GitHub - ReactiveX/RxAndroid: RxJava bindings for Android