Reactive Extensions再入門 その２９「値を指定した時間だけ遅延させるDelayメソッド」

過去記事インデックス

• Reactive Extensions再入門 その１
• Reactive Extensions再入門 その２「IObservableインターフェースとIObserverインターフェース」
• Reactive Extensions再入門 その３「IObservableのファクトリメソッド」
• Reactive Extensions再入門 その４「Timer系のファクトリメソッド」
• Reactive Extensions再入門 その５「HotとCold」
• Reactive Extensions再入門 その６「HotなIObservableを作成するファクトリ」
• Reactive Extensions再入門 その７「LINQスタイルの拡張メソッド」
• Reactive Extensions再入門 その８「SkipとTakeメソッド」
• Reactive Extensions再入門 その９「Skip + Take + Repeat = ドラッグ」
• Reactive Extensions再入門 その１０「Doメソッド」
• Reactive Extensions再入門 その１１「Catchメソッド」
• Reactive Extensions再入門 その１２「Finallyメソッドとリソース解放」
• Reactive Extensions再入門 その１３「最後の値を取得するLatestとMostRecentメソッド」
• Reactive Extensions再入門 その１４「Nextメソッド」
• Reactive Extensions再入門 その１５「To*****系メソッド」
• Reactive Extensions再入門 その１６「最大、最少、平均を求めるメソッド」
• Reactive Extensions再入門 その１７「集計するメソッド」
• Reactive Extensions再入門 その１８「CountメソッドとLongCountメソッド」
• Reactive Extensions再入門 その１９「AnyメソッドとAllメソッド」
• Reactive Extensions再入門 その２０「GroupByメソッドでグルーピングしてみよう」
• Reactive Extensions再入門 その２１「GroupByUntilメソッド」
• Reactive Extensions再入門 その２２「単一の値を取得するメソッド」
• Reactive Extensions再入門 その２３「重複を排除するメソッド」
• Reactive Extensions再入門 その２４「単一の値を取得するメソッド その２」
• Reactive Extensions再入門 その２５「値をまとめるBufferメソッド」
• Reactive Extensions再入門 その２６「値をまとめるWindowメソッド」
• Reactive Extensions再入門 その２７「時間でフィルタリング？Sampleメソッド」
• Reactive Extensions再入門 その２８「落ち着いたら流すThrottleメソッド」

• Reactive Extensions再入門 番外編「センサー監視」
• Reactive Extensions再入門 番外編「System.Reactive.Linq.Observableのメソッド一覧とメモ」

はじめに

今回は、Delayメソッドです。Reactive Extensionsのデモとして、とても魅せやすいメソッドですね！シンプルなのでさくっといきましょう。

Delayメソッド

ここでは、Delayメソッドについて説明します。Delayメソッドは名前が示す通りIObservableのシーケンスから発行された値を指定した時間だけ遅延させて後続に流すメソッドになります。
メソッドのシグネチャを以下に示します。

public static IObservable<T> Delay<T>(
    this IObservable<T> source, 
    TimeSpan dueTime);

引数のdueTimeで遅延させる時間を指定します。TimeSpan型を受け取る以外にも、特定の時点まで遅延させることも出来ます。このメソッドのコード例を下記に示します。

var source = new Subject<int>();
source
    // 10秒遅延させる
    .Delay(TimeSpan.FromSeconds(10))
    // 値を時間つきで表示させる
    .Subscribe(i =>
        Console.WriteLine("{0:HH:mm:ss.fff} {1}", DateTime.Now, i));

// 1秒間隔で1〜5の値を発行
foreach (var i in Enumerable.Range(1, 5))
{
    Console.WriteLine("{0:HH:mm:ss.fff} OnNext({1})", DateTime.Now, i);
    source.OnNext(i);
    Thread.Sleep(1000);
}

// 終了待ち
Console.WriteLine("Please enter key");
Console.ReadLine();

Delayメソッドを使ってIObservableのシーケンスから発行された値を10秒遅延させています。実行結果を以下に示します。

21:58:12.174 OnNext(1)
21:58:13.202 OnNext(2)
21:58:14.202 OnNext(3)
21:58:15.202 OnNext(4)
21:58:16.202 OnNext(5)
Please enter key
21:58:22.214 1
21:58:23.205 2
21:58:24.202 3
21:58:25.216 4
21:58:26.215 5

実行結果からわかるように、OnNextで発行した値が10秒後に表示されています。このようにDelayメソッドを使うと、値を遅延させて後続に流すということが実現できます。