RxJS を学ぼう #4 - COLD と HOT について学ぶ / ConnectableObservable wakamsha これはいわゆる『COLD』という性質に限った話であり、実は Observable には subscribe せずともデータを流す仕組みが用意されています。そのような性質を『HOT』と呼びます。この二つの性質の違いを理解することは Rx を使いこなす上で避けて通ることは出来ません。今回はこれら COLD と HOT についてご紹介します。 COLD 1) subscribe されるまで値を流さない COLD は下流で subscribe されるまで値を流しません ( ストリームが稼働していない状態 ) 。仮に subscribe されていない Observable に値を流しても流れが途切れるだけで、値は処理されることなく消滅してしまいます。通常、Observa
Subjects in RxJS are often misunderstood. Because they allow you to imperatively push values into an observable stream, people tend to abuse Subjects when they’re not quite sure how to make an Observable out of something. The pattern looks a little like this… // What people usually first do with Subjects when they find them // (TRY NOT TO DO THIS)const subject = new Subject(); button.addEventListe
この記事は、[学生さん・初心者さん大歓迎！]Xamarin Advent Calendar 2016 の9日目の記事です。 はじめに Androidなんかでは、アプリ設計をどのようにするかは結構白熱した議論がされており、MVPだMVCだCleanArchitectureだみたいな感じでビシっと決まっていないのが現状です。 一方で、Xamarin.FormsではMVVMを用いるのがほぼスタンダードとなっており、Prism for Xamarin.Forms や MVVM Light Toolkit といったライブラリによってMVVMでやれば楽という環境が整っています。 この記事では、そんな中でなんとかReactiveExtensions(Rx)+Fluxを使っていい感じにできないかというのを実践してみた記事になります。 Rxとは ReactiveExtensions(Rx)は、C#のLINQ
Subscription disposables now only create strong references to sinks until being disposed or sequence terminates. #573 Introduces SharedSequence and makes Driver just a specialization of SharedSequence. That means Driver is now just one specific SharedSequence and it is now possible to easily create new concepts that have another compile time guarantees in a couple of lines of code. E.g. choosing a
(2016/12/15追記) この記事はDeprecatedです。 Reduxの概念をRxJSとTypeScriptで理解する ver.2 が最新版になります。 GitHubリポジトリはこちら → ovrmrw/understanding-redux-with-rxjs git cloneしたらnpm installしてnum run tsですぐに動かせます。 (注: Reactの話は一切出てきません) Reduxとは Redux公式 アプリケーション全体で状態(state)を一つのJSONツリーの構造で持ち、それをActionがキックされる度に全体更新して配信するという概念。 僕は最初FluxとかReduxとかよくわからなかったけど、色々参考にしながら自分で書いてみたらようやく理解できました。 Middlewareという概念はよくわからなかったし今でもよくわかりません。 ロガーとか便利な
RxJavaではObservableでExceptionが発生した場合、デフォルトではそのObservableを監視しているObserverのonErrorメソッドが実行され、出力元のObservableが終了します。 想定外のエラーが発生して処理を続行することが困難な場合はonErrorで適切な後処理をしてやればよいですが、想定されたエラーの場合はエラーをハンドリングして別の処理に分岐させたいというケースもよくあるかと思います。 今回はRxJavaのonError以外のエラーハンドリングメソッドを試して、それぞれのメソッドごとの違いを理解することでエラーをより柔軟に扱う方法を学んでみます。 Catch Operator onError onErrorReturn onErrorResumeNext onExceptionResumeNext 参考 Catch Operator RxJav
この記事は bouzuya's RxJS Advent Calendar 2015 の 9 日目かつ RxJS Advent Calendar 2015 の 9 日目です。 はじめに 今日は ReactiveX の Observable Utility Operators について RxJS の API ドキュメントやサンプルコードを書いていきます。 また RxJS 4.0.7 を対象にしています。 Observable Utility Operators Observable.prototype.subscribe ReactiveX - Subscribe operator Observable.prototype.subscribe API Document Observable.prototype.subscribe Source Code リスト上は subscribe が挙げら
Angular2, npm3, RxJS, TypeScript, System.js 【beta.0対応版】 Angular2はalpha.47まではそこまでBreaking Changesが無かったような気がするのですが、ここ最近のアップデートはガンガンBreakingしています。 angular2-polyfills.jsの読み込みが必要になった alpha.54からはangular2.dev.jsの前にポリフィルの読み込みが必要になりました。 <script src="../node_modules/angular2/bundles/angular2-polyfills.min.js"></script> <script src="../node_modules/angular2/bundles/angular2.dev.js"></script> これが足りないといくらブラウザを
import React from 'react' import ReactDom from 'react-dom' import { createStore, applyMiddleware } from 'redux' import { createEpicMiddleware } from 'redux-observable' import { connect, Provider } from 'react-redux' // rxjsハマり部分。後述 import 'rxjs/add/operator/mapTo' import 'rxjs/add/operator/filter' import 'rxjs/add/operator/delay' // sampleにあるreducer const pingReducer = (state = { isPinging: false
Hi, I'm almost new to Rx and trying to understand the philosophy of reactive programming. 😄 I encountered the problem in error handling. I read many articles such as #316, #618 but I could not figure out how to handle errors without nesting flatMap or using Result model. The code below is very similar to GitHubSignUp example in RxExample project. User inputs are passed to usernameInputDidReturn,
Pt — A code experiment on point, form, and space.Reactive Extensions for JavaScript (RxJS) is a reactive streams library that allows you to work with asynchronous data streams. RxJS can be used both in the browser or in the server-side using Node.js. In this post we are going to introduce RxJS basic concepts and how we can use them with AngularJS. Follow me on Twitter for latest updates @gerardsan
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
