RxJavaでイベントバスを実装する
RxJavaは、連鎖的な非同期処理だけでなく、イベントバスとしてメッセージやイベントの伝達機能を実現するためにも活用できます。ここでは、RxJavaを用いたRxBusの実装方法と利用例について解説します。
RXBUSの実装
RxJavaでイベントバスを実装するためのクラスです。
import java.util.HashMap;
import java.util.Map;
import rx.Observable;
import rx.Subscription;
imp ...
11月1日 15:51 投稿
ReactiveX における集計操作符の実装
数学的・集計操作符
本稿では、Observable(可観測データストリーム)に対する集計操作符について解説します。
Average(平均値)
Average操作符は、ソースデータストリームの全データの平均値を計算し、その平均値を出力します。
// C# (Rx.NET)
var source = new Subject<int>();
source.Average().Subscribe(avg =>
{
Console.WriteLine("Average: {0} ...
7月14日 21:51 投稿
RxSwift と RxCocoa を用いた MVVM パターンによるリアクティブ UI 実装
UIKit におけるユーザーインターフェースの状態管理を、リアクティブプログラミングで簡潔に実現する方法について解説します。ここでは RxSwift、RxCocoa、および MVVM アーキテクチャを組み合わせて、動的なデータバインディングを構築します。
要件
画面には3つのテキストフィールド(UITextField)と1つのラベル(UILabel)を配置
ラベ ...
6月11日 19:30 投稿