Subject にいくつかオペレータを敵賞して Subscribe する場合と Subject 以外のたとえば Range にいくつかオペレータを適用して Subscribe する場合 について、Observer にどのようにして値が流れるのか見ていきます。 まずは Subject から。 using System; …

下のコードは、1 秒、3 秒、4 秒後にイベントを発行するサンプルです。 using System; using System.Linq; using UniRx; using UniRx.Diagnostics; using UnityEngine; public class Main : MonoBehaviour { void Start() { var fireTimes = new[] { 1, 3, 4…

qiita.com 上の記事を読んで、サンプルコードを書いてみました。 using System; using System.Collections.Generic; using System.Linq; class Program { static void Main() { var a = new List<Action>(); var b = new List<Action>(); for (int i = 0; i < 3; i++) { a.Ad</action></action>…

Subject クラスへの購読と、その購読のキャンセル処理について以下のサンプルコードで見ていきます。 using UniRx; using UnityEngine; public class Main : MonoBehaviour { void Start() { var subject = new Subject<int>(); // 購読する var disposable = sub</int>…

Subject の定義をみると次のようになっています。 public sealed class Subject<T> : ISubject<T>, IDisposable, IOptimizedObservable<T> { } ISubject の定義は、 public interface ISubject<TSource, TResult> : IObserver<TSource>, IObservable<TResult> { } public interface ISubject<T> : ISubject<T, T>, I</t,></t></tresult></tsource></tsource,></t></t></t>…

以下のサンプルは、1 秒ごとにテキストを更新するサンプルです。 using System; using UniRx; using UnityEngine; using UnityEngine.UI; public class Main : MonoBehaviour { [SerializeField] private Text _text = null; void Start() { Observable.Inte…

Observable.DistinctUntilChanged は同じ値を連続して流さないオペレータです。 using UniRx; using UniRx.Diagnostics; using UnityEngine; public class Main : MonoBehaviour { void Start() { var s = new[] {1, 2, 3, 2, 2, 2, 5, 5} .ToObservable() .…

UniRx: Hot と Cold (1) - C#練習日記 の続きです。63 of 115 からです。 Cold な Observable は分岐できない Cold な Observable は Observer をひとつしか持てません。 using System; using UniRx; using UnityEngine; public class Main : MonoBehaviour …

Rx の Hot, Cold について、以下のスライドが参考になります。 今日こそ理解するHot / Cold @社内RxSwift勉強会 from Yuki Takahashi www.slideshare.net このスライドではプログラミング言語として Swift を採用していますが、Rx は特定のプログラミング言…

Observable.Distinct は、ストリームに重複値を流さないようにするオペレータです。 using UniRx; using UniRx.Diagnostics; using UnityEngine; public class Main : MonoBehaviour { void Start() { var s = new[] {1, 2, 3, 2, 2, 5, 5} .ToObservable() …

Observable.FromCoroutineValue() でコルーチンを IObservable 化することができます。 コルーチンの yield return の値が OnNext に渡ります。 using System; using System.Collections; using UniRx; using UniRx.Diagnostics; using UnityEngine; public …

Rx には From というオペレータがあります。 UniRx には From が定義されてないようですが、ToObservable() というのがあります。 このメソッドを使うと、IEnumerable<T> を IObservable<T> に変換できます。 using UniRx; using UniRx.Diagnostics; using UnityEn</t></t>…

ObservableDebugExtensions.cs に Debug() 拡張メソッドが定義されています。 この拡張メソッドを使うと、OnNext や OnCompleted などのイベント時にログが出力されるようになります。 (これはデバッグ機能として提供されており、DEBUG シンボルが定義されて…

Observable.Delay() は通知データを好きな期間だけ遅らせることができるオペレータです。 using System; using UniRx; using UnityEngine; public class Main : MonoBehaviour { void Start() { Debug.Log("Start"); var s = Observable.Range(10, 3).Delay(…

Observable.Empty() は、Subscribe() するとすぐに完了を通知します。 using UniRx; using UnityEngine; public class Main : MonoBehaviour { void Start() { var s = Observable.Empty<Unit>(); s.Subscribe(e => Debug.Log("e: " + e), () => Debug.Log("OnComp</unit>…

.NET API ブラウザー | Microsoft Docs Source Browser 例えば System.Collections.Generic.List<T> を検索するには class List< まで入力すると検索候補にでてきます(List で検索するとマッチ候補が多くて探しにくくなります)。</t>