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 投稿
RxJavaにおけるリアクティブプログラミングとバックプレッシャー
1. 概念
リアクティブプログラミングは、データストリームと変化の伝播に焦点を当てたプログラミングパラダイムです。これには3つのキーワードが含まれ、以下のように説明できます。
【データストリーム】あらかじめ決められた順序で一度だけ読み取られるデータのシーケンスです。
コンピュータでは受け渡されるデータを指し、現実世界では任意のオブジェクトからなる順序 ...
10月16日 19:46 投稿
ReactiveX における集計操作符の実装
数学的・集計操作符
本稿では、Observable（可観測データストリーム）に対する集計操作符について解説します。
Average（平均値）
Average操作符は、ソースデータストリームの全データの平均値を計算し、その平均値を出力します。
// C# (Rx.NET)
var source = new Subject<int>();
source.Average().Subscribe(avg =>
{
Console.WriteLine("Average: {0} ...
7月14日 21:51 投稿
Hystrixの動作原理と実装解析
Hystrixの基本コンセプト
クラスレベルでのカスタム設定
柔軟なフォールバック戦略の設定:
セマフォ/スレッド / タイムアウト（1秒）、サーキットブレーカー（エラーレート）
HystrixCommandProperty
フォールバック境界の特定方法:
@HystrixCommand(Spring AOP)
HystrixCommand 抽象クラス
データ収集:
サーキットブレーカーのトリガー条件（10秒 / 20リクエスト ...
6月17日 19:53 投稿
Androidにおける画像選択機能の設計と実装：RxImagePickerによるリアクティブアプローチ
RxImagePickerを用いた柔軟な画像選択アーキテクチャ
RxImagePickerは、Androidアプリにおいて画像の選択・撮影操作を簡素化するためのリアクティブライブラリです。RxJava2/RxJava3との統合により、非同期処理やイベントストリームの管理が容易になり、開発者はUIロジックに集中できます。本稿では、基本的な統合からカスタムUIの構築まで、実践的な実装パターンを解説し ...
6月7日 20:48 投稿
RxJavaユーティリティオペレーター入門：遅延、デバッグ、リソース管理
RxJava を使用する際、データストリームの処理をより柔軟かつ効果的に行うために、様々なユーティリティオペレーターが提供されています。本記事では、データストリームのタイミング制御、デバッグ、リソース管理に役立つ主要なオペレーターについて解説します。
RxJava のオペレーターは、Observable (観測可能なシーケンス) から新しい Observable を生成することで、デ ...
5月26日 09:07 投稿