Reactive Extensions再入門その３１「時間に関する情報を付与するTimestampとTimeIntervalメソッド」

link管理

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

相关文章推荐

被表白的书签 · NPM Sonar Scanner ...· 14 小时前 ·

奋斗的豆浆 · Error loading ...· 3 周前 ·

酷酷的煎鸡蛋 · [CMake] Dependency ...· 3 周前 ·

开朗的骆驼 · java匿名函数的作用是什么？ - 知乎· 12 月前 ·

宽容的毛衣 · “豁车”变“豁命”· 1 年前 ·

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再入門その２９「値を指定した時間だけ遅延させるDelayメソッド」

Reactive Extensions再入門その３０「もう待ちきれない！を表現するTimeoutメソッド」

Reactive Extensions再入門番外編「センサー監視」

Reactive Extensions再入門番外編「System.Reactive.Linq.Observableのメソッド一覧とメモ」

個人的には、単発メソッドの紹介はそろそろおおづめ。今回はデバッグに便利そうなメソッドについて紹介します。

時間に関する情報を付与する拡張メソッド

ここでは、IObservable のシーケンスに対して時間に関する情報を付与するIObservable の拡張メソッドについて説明します。

Timestampメソッド

ここでは、Timesptampメソッドについて説明します。Timestampメソッドは、IObservable のシーケンスに対して、その名の通りタイムスタンプを追加するメソッドです。メソッドのシグネチャを以下に示します。

public static IObservable<Timestamped<T>> Timestamp<T>(this IObservable<T> source);

戻り値がIObservable >型になっています。このTimestamped 型は以下のように定義されています。（演算子のオーバーロード等は省いています）

using System;
namespace System.Reactive
    public struct Timestamped<T>
        public DateTimeOffset Timestamp { get; }
        public T Value { get; }

Timestampプロパティで、時間を取得しValueプロパティで値を取得するシンプルな構造体です。コード例を下記に示します。

var subscriber = Observable
    // 1秒間隔で0〜4の値を発行
    .Generate(0, i => i < 5, i => i + 1, i => i, _ => TimeSpan.FromSeconds(1))
    // タイムスタンプをつける(Timestamped<T>型になる)
    .Timestamp()
    // 購読
    .Subscribe(
        i => Console.WriteLine("Timestamp: {0}, Value: {1}", i.Timestamp, i.Value));
// 終了待ち
Console.WriteLine("Please enter key.");
Console.ReadLine();
subscriber.Dispose();

1秒間隔で0〜4の値を発行して、それにTimestampメソッドを呼び出してTimestamped 型に変換しています。そしてSubscribeでTimestampとValueを表示しています。実行結果を以下に示します。

Please enter key.
Timestamp: 2012/02/05 22:47:59 +09:00, Value: 0
Timestamp: 2012/02/05 22:48:00 +09:00, Value: 1
Timestamp: 2012/02/05 22:48:01 +09:00, Value: 2
Timestamp: 2012/02/05 22:48:02 +09:00, Value: 3
Timestamp: 2012/02/05 22:48:03 +09:00, Value: 4

値が発行された時の時間が表示されていることが確認できます。

TimeIntervalメソッド

ここでは、TimeIntervalメソッドについて説明します。TimeIntervalメソッドはIObservable のシーケンスから発行された値の間隔をTimeSpan型で追加します。メソッドのシグネチャを以下に示します。

public static IObservable<TimeInterval<T>> TimeInterval<T>(this IObservable<T> source);

戻り値が、IObservable >型になっています。TimeInterval 型は以下のように定義されています。（演算子のオーバーロード等は省いています）

using System;
namespace System.Reactive
    public struct TimeInterval<T>
        public TimeSpan Interval { get; }
        public T Value { get; }

Intervalプロパティで時間間隔を取得し、Valueプロパティで値を取得するシンプルな構造体です。コード例を下記に示します。

var subscriber = Observable
    // 1秒間隔で0〜4の値を発行
    .Generate(0, i => i < 5, i => i + 1, i => i, _ => TimeSpan.FromSeconds(1))
    // 値の発行間隔をつける(TimeInterval<T>型になる)
    .TimeInterval()
    // 購読
    .Subscribe(
        i => Console.WriteLine("Interval: {0}, Value: {1}", i.Interval, i.Value));
// 終了待ち
Console.WriteLine("Please enter key.");
Console.ReadLine();
subscriber.Dispose();

1秒間隔で0〜4の値を発行して、それにTimeIntervalメソッドを呼び出してTimeInterval 型に変換しています。そしてSubscribeでIntervalとValueを表示しています。実行結果を以下に示します。

Please enter key.
Interval: 00:00:01.0050575, Value: 0
Interval: 00:00:01.0150581, Value: 1
Interval: 00:00:01.0140580, Value: 2
Interval: 00:00:01.0140580, Value: 3
Interval: 00:00:01.0120578, Value: 4

値が発行された間隔が表示されていることが確認できます。