)
Reactive Extensions
Reactive Extensions (Rx) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators. Data sequences can take many forms, such as a stream of data from a file or web service, web services requests, system notifications, or a series of events such as user input. Reactive Extensions represents all these data sequences as observable seque
ReactiveX - Links to More Information
Introductions Introduction to Rx: a free, on-line book by Lee Campbell Your Mouse is a Database by Erik Meijer The introduction to Reactive Programming you’ve been missing by André Staltz Mastering Observables from the Couchbase documentation 33rd Degree Reactive Java by Tomasz Kowalczewski 2 minute introduction to Rx by André Staltz Wikipedia: Reactive Programming and Functional Reactive Programm
Reactive Extensionsのはじめかた - かずきのBlog@hatena
最近Reactive Extensionsがバズってきてて、2年以上前に公開したReactive Extensionsのv1のメソッドを大体網羅したPDFが割と参照されてます。 Reactive extensions入門v0.1 from 一希 大田 www.slideshare.net 個人的な入門は、そこに全部書いたので今更感もありますが、Reactive Extensionsを今から入門する人向けに色々書いてみたいと思います。 Reactive Extensionsとは IObservable<T>とIObserver<T>がコアのインターフェースになります。名前からわかるようにこれは、GoFのデザインパターンの1つ、オブザーバーパターンを表したインターフェースになります。 Observerパターン Observerパターンを簡単に説明すると、IObservableの状態に何かしら変
RxJS を学ぼう #5 - Subject について学ぶ / Observable × Observer | Recruit Tech Blog
RxJS を学ぼう #5 - Subject について学ぶ / Observable × Observer wakamsha RxJS にはイベントストリームを流す『Observable』とそこを流れる値を受け取る『Observer』と二人の役者がいますが、一人二役をこなすものが別にいます。それがSubjectです。今回はこの Subject について詳しくご紹介します。 RxJS/subjects.md at master · Reactive-Extensions/RxJS 【おさらい】COLD の場合、Observable はそれぞれの Observer に対して個別に値を流す RxJS を学ぼう #4 - COLD と HOT について学ぶ / ConnectableObservable Subject を理解するにはまず『COLD』と『HOT』の概念が頭に入っていなくてはなりませ
RxJS を学ぼう #4 - COLD と HOT について学ぶ / ConnectableObservable | Recruit Tech Blog
RxJS を学ぼう #4 - COLD と HOT について学ぶ / ConnectableObservable wakamsha これはいわゆる『COLD』という性質に限った話であり、実は Observable には subscribe せずともデータを流す仕組みが用意されています。そのような性質を『HOT』と呼びます。この二つの性質の違いを理解することは Rx を使いこなす上で避けて通ることは出来ません。今回はこれら COLD と HOT についてご紹介します。 COLD 1) subscribe されるまで値を流さない COLD は下流で subscribe されるまで値を流しません ( ストリームが稼働していない状態 ) 。仮に subscribe されていない Observable に値を流しても流れが途切れるだけで、値は処理されることなく消滅してしまいます。通常、Observa
RxJS を学ぼう #3 - 知ってると便利な ( かもしれない ) オペレータ 8選 | Recruit Tech Blog
RxJS を学ぼう #2 – よく使う ( と思う ) オペレータ15選 というエントリにて『頻出するオペレータ』をご紹介しました。RxJS 5.x系には約90ものオペレータがありますが、いきなりその全てを習得するのは無理がありますし必ずしも全てを知る必要はありません。 今回は前回ご紹介したものほど使う頻度は高くないけど、知っているとなにかと便利なオペレータをご紹介します。前回と今回のを合わせればそこそこのアプリケーションは作れてしまうのではないでしょうか。 Observable.do Observable ソースから流れてくる全ての値に対して任意の処理 ( 副作用 ) を実行します。ただし、do の戻り値は ソースから流れてきた Observable そのままで、副作用の結果は流れません。 const clicks = Rx.Observable.fromEvent(document.q
RxJS を学ぼう #2 - よく使う ( と思う ) オペレータ15選
RxJS 5.x系には約90ものオペレータがありますが1)4.x系の頃は約140あったので、これでも相当少なくなった方なのです…、いきなりその全てを習得するのは無理がありますし必ずしも全てを知る必要はありません。頻繁に利用するのはそのうちのごく一部であり、あくまで所感ですが二十も覚えれば大概のアプリは作れることでしょう。 今回はいま現在実際に開発している弊社プロダクトのコードから特に使用頻度の高いオペレータ15個をご紹介します。 RxJS/categories.md at master · Reactive-Extensions/RxJS rxjs/MIGRATION.md at 5.0.0-beta.0 · ReactiveX/rxjs Converting events to Operators Observable.of 引数に渡された値をそのまま流して終了するだけの Observa
RxJS を学ぼう #1 - これからはじめる人のための導入編 | Recruit Tech Blog
React の登場と共に web フロントエンド界隈でも注目を集めるようになったリアクティブ・プログラミング ( RP ) 。その中でひときわ存在感を放っている1)オレ調べ。 RxJS について学んでみようと思います。 ReactiveX そもそも RxJS って何？ RxJS は Reactive Extensions for JavaScript の略称です。Observables というアーキテクチャを用いたリアクティブ・プログラミング用のライブラリであり、非同期処理 ( クリックなどイベント駆動の処理も含まれます ) を簡潔かつ可読性高くコーディング出来ることを主な目的としています。 で？Reactive Extensions ( Rx ) って何？ 元々は Microsoft が C# 向けのライブラリとして設計・開発したものです。2009年に始動したプロジェクトから生まれたこの
RxJS Real World // Speaker Deck
All slide content and descriptions are owned by their creators.
Model View Whatever + Rx のアンチパターン - Re.Ra.Ku tech blog
GUIアーキテクチャパターンとしてModel View Whateverを採用した際に、Rxのストリームをプレゼンテーション層からモデル層まで一気通貫でつなげてしまうのはアンチパターンである、という話をします。 前提 GUIアーキテクチャパターンにおける Model View Whatever パターン、とくにMVVMに近いパターンを前提とします。いわゆるサーバサイドの「web系MVC」は前提としません。 Model View WhateverパターンとPDS そもそもGUIアプリケーションでModel View Whateverというアーキテクチャパターンを採用する理由として、PDSの実現があります。このあたりの話は詳しくは実況中継シリーズ Vue.jsで実現するMVVMパターン Fluxアーキテクチャとの距離 - Re.Ra.Ku アドベントカレンダー day 13 - Re.Ra.K
RxのHotとColdについて - Qiita
UniRxについての記事のまとめはこちら RxのIObservable<T>にはHot/Coldという大きな2つの特徴があります。 これら性質を理解しないままストリームを設計すると、意図した動作をしてくれない場合があります。 今回はこのHot/Coldの性質について簡単にまとめたいと思います。 概要 一言で言うと？ Cold : ストリームの前後をつなぐだけのパイプ。単体では意味が無い。だいたいのオペレータはこっち。 Hot : ストリームから値を発行し続ける蛇口。常に垂れ流し。後ろにパイプがたくさん接続できる。 細かく説明すると Cold Observable 自発的に何もしない受動的なObservable Observerが登録されて（Subscribeされて）初めて仕事を始める ストリームの前後をただつなぐだけ。ストリームを枝分かれさせる機能は無い。 Hot Observable 自
はじめてのReactor Core - CLOVER🍀
Reacive〜と名の付くものに関する話題について、そろそろ少しずつ追ってみようかなということで。 とりあえず、触りつつ試しつつ始めてみようと思い、まずはReactorを触ってみることにしました。 Project Reactor GitHub - reactor/reactor: Reactor BOM and legacy (2.x, 1.x) Reactorとは、Pivotalが開発しているReactive Streamsの実装っぽいです。 Reactive Webアプリケーション - そしてSpring 5へ #jjug_ccc #ccc_ef3 まあ、いろいろ難しいことは抜きにして、単純に動かしてみましょう。 準備 今回は、Reactor Coreを使ってコードを書いて試すことにします。 GitHub - reactor/reactor-core: Non-Blocking Rea
JavaでReactiveプログラミング ~Reactor~ - Qiita
突然ですが、先日参加したJJUG ccc fallでReactiveStreams/ReactiveExtensionsという仕様とそのJava実装の一つであるReactorというものを知りました。 JJUG ccc fallでReactiveStreamsとかとかを知ったセッション Reactive Streams Reactor リアクティブ~~についてものすごく参考になった資料 リアクティブなJavaといえばRxJavaだと思っていましたが、いろいろあるもんですね。 RxJavaもReactiveStreamsが実装されているようです。 https://github.com/ReactiveX/RxJava RxJavaは触ってみたことがあったので、今回はReactorについてコードを交えながらつらつらと書いていきたい。 ふわっとしているリアクティブプログラミングというものを少しでも
Everything is a stream, ViewModel is 何？ - Qiita
via Rob Wormald いいコトバですね。 Android アプリ開発では、事実上 stream is an (RxJava の) Observable<T>、 つまり Everything is an Observable<T> と言ってもいいでしょう。 ところで、 Android アプリ開発でも DataBinding の登場以来、MVVM パターンの話題が増えてきました。 Everything is a Observable<T>、では ViewModel はどうでしょう？ public class MainViewModel { public final ObservableField<String> name = new ObservableField<>(); public final ObservableField<String> location = new Obs
%253A_TestSubscriber%252C_test()%252C_TestScheduler)
RxJava のテスト(1): TestSubscriber, test(), TestScheduler - hydrakecat’s blog
これはRxJava Advent Calendar 2016の第12日目の記事です。 RxJavaは非同期処理を扱うライブラリですが、それ故にRxJavaのからむ単体テストは一筋縄でいかないところがあります。この記事と次の記事では、RxJavaでの非同期処理テスト特有の問題と、その解決方法を説明します。なお、基本的に RxJava 1.x を対象としていますが、必要に応じて RxJava 2.x についても触れます。 この記事の続編はこちらになります。 非同期処理の単体テストの難しさ 非同期処理の単体テストは一般に難しいものです。試しに以下のコードを実行してみましょう。 @Test public void testDoSomething() { new AsyncService().doSomething() .subscribe(s -> assertEquals("success",
関数型プログラマのための Rx 入門（前編） - Okapies' Archive
概要 『Observable は単なる非同期データストリームにおけるモナドのインスタンスだよ。何か問題でも？』 まともな概要 つまり、Reactive Extensions (Rx) って何だ？ ということでウェブをガサゴソと漁っていたところ、オンライン講義サービス Coursera の Principles of Reactive Programming に行き当たった。この講座では、Rx の主要開発者の一人である「双対おじさん」こと Erik Meijer 氏自らが一部の章を担当し、Rx の理論的側面を講義している。 この講座の大きな特徴は、Rx を（命令型プログラミングではなく）関数型プログラミング (FP) の側から解き明かしていくことにある。 こう書くと奇をてらっているように見えるかもしれないが、実際には Rx は FRP (Functional Reactive Program
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Rx入門