UniRx: TakeUntil

TakeUntil は引数で渡した IObservable が最初のデータを通知したら、自身の通知をそこで終了させるオペレータです。 以下のサンプルは、1 秒ごとにデータを通知しますが、スペースキーが押されると、そこで通知を終了します。 using System; using UniRx; u…

UniRx: Take と First と Single

Take, First, Single の各オペレータは、ストリームに流れる値を取り出します。 オペレータに応じて、それぞれストリームにいくつ値がながれるか、期待する個数が異なります。 Take は、ストリームの最初の N 個を取り出します(N は引数で指定)。不足があっ…

UniRx: Subject とそれ以外のソースでのストリームの流れを眺める

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

UniRx: 時間を(複数)指定してイベント発行

下のコードは、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…

一時変数のキャプチャ。C# 5.0 の foreach の破壊的変更

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>…

UniRx: Subject への購読とそのキャンセル処理を眺める

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

UniRx: Subject は IObserver であり IObservable でもある

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>…

UniRx: SubscribeWithState は Subscribe より効率がよい

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

UniRx: DistinctUntilChanged

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 (2)

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

UniRx: Hot と Cold (1)

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

UniRx: Distinct

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() …

UniRx: コルーチンを IObservable 化する

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

UniRx: ToObservable() が From() に代わりになるのかな

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

UniRx: Debug() 拡張メソッド

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

UniRx: Delay

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

UniRx: Empty

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 Core API リファレンスと .NET Core Source Browser のURLのメモ

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

UniRx: Concat

Observable.Concat() は複数の IObservable<T> を順番に実行するオペレーターです。 using System; using UniRx; using UnityEngine; public class Main : MonoBehaviour { void Start() { // 1 秒ごとに通知 var a = Observable.Interval(TimeSpan.FromSeconds</t>…

UniRx: 購読をキャンセルする

IObservable<T>.Subscribe() から返却される IDisposable の Dispose() を呼び出すと購読がキャンセルされます。 using System; using UniRx; using UnityEngine; public class Main : MonoBehaviour { private IDisposable _disposable; void Start() { var s </t>…

UniRx: AddTo() 拡張メソッドのソースを読む

この記事では、AddTo() 拡張メソッドを用いると、ゲームオブジェクトの破棄タイミングで購読を破棄する仕組みを眺めていきます。 次のサンプルコードでは、Observable.Interval() で一定時間ごとにログを出力します。 また、スペースキーを押すとシーンが切…

UniRx: Observable.ReturnUnit のソースを読む

Observable.ReturnUnit のサンプルコード using System; using UniRx; using UnityEngine; public class Main : MonoBehaviour { void Start() { var s = Observable.ReturnUnit(); s.Subscribe(e => Debug.Log("e: " + e), () => Debug.Log("OnCompleted"))…

UniRx: Start

Observable.Start メソッドは、引数で指定した Func<T> 関数から生成したデータを通知します。 using System; using UniRx; using UnityEngine; public class Main : MonoBehaviour { private IObservable<DateTime> _observable; void Start() { _observable = Observabl</datetime></t>…

UniRx: Return

void Start() { var s = Observable.Return(100); s.Subscribe(e => Debug.Log(e), () => Debug.Log("OnCompleted")); } 実行結果です。 100 OnCompleted UniRx の Return の実装を読む。パフォーマンスを上げるために、通知する値の型に応じて実装をもって…

ToLookup 拡張メソッド

以前に Partition 関数 - C#練習日記 を作りましたが、 Linq には ToLookup 拡張メソッド があり、このメソッドを使うことで同様のグルーピングを行うことができます。 using System; using System.Linq; class Program { static void Main() { var xs = new…

プロパティへの代入がコンストラクタ内のみなら、そのプロパティに private set を定義する必要はない

using System; class Person { public string Name { get; } // 代入はコンストラクタでのみ。private set; は不要 public int Age { get; } public Person(string name, int age) { Name = name; Age = age; } } class Program { public static void Main()…

N 番目の要素を O(1) で取得する Cycle クラスを作る

数列 a = { 0, 1, 0, -1, 0, 1, 0, -1, 0, 1, 0, -1, ... } のような 4 周期で繰り返す数列で、かつ N 番目の要素を O(1) で取得する Cycle クラスを作ってみました。 // 0, 1, ... を繰り返す数列 var zeroOne = new Cycle<int>(new[] { 0, 1 }); Console.WriteL</int>…

エラトステネスの篩

haskell.g.hatena.ne.jp 上の記事をみて、エラトステネスの篩を C# で書いてみました。 // 2, 3, 4, 5, ... static IEnumerable<int> Nums() { int n = 2; while (true) yield return n++; } static Func<int, bool> MakePrimeFilter(int prime, Func<int, bool> isPrime) { // x はこれ</int,></int,></int>…

IEnumerable<T> のランダムな要素を選択する

d.hatena.ne.jp 上の記事で紹介されている「要素全体をメモリに保持せずに、ランダムな要素を選択する」アルゴリズムが面白いです。 C# で書いてみました。 public static class Extensions { // source が空だったり、配列やリストの場合の対応は後述 publi…

インターフェース型の変数への代入と 3 項演算子を組み合わせるとコンパイルエラーになる

クラス A と、クラス B が IDisposable を実装しているとします。 そのときに、3 項演算子を用いて、以下のように書くことはできないようです。 class A : IDisposable { ... } class B : IDisposable { ... } // コンパイルエラーになる: There is no impli…