IConnectableObservable<T> インターフェイス

接続および切断できる監視可能な値を表します。

名前空間:System.Reactive.Subjects
アセンブリ: System.Reactive (System.Reactive.dll内)

構文

'Declaration
Public Interface IConnectableObservable(Of Out T) _
    Inherits IObservable(Of T)

'Usage
Dim instance As IConnectableObservable(Of Out T)

public interface IConnectableObservable<out T> : IObservable<T>

generic<typename T>
public interface class IConnectableObservable : IObservable<T>

type IConnectableObservable<'T> =  
    interface
        interface IObservable<'T>
    end

JScript does not support generic types and methods.

型パラメーター

• outT
  型。

  この型パラメーターは共変です。 つまり、指定した型またはより派生した任意の型を使用できます。 共変性と反変性の詳細については、を参照してください。

IConnectableObservable<T> 型は、次のメンバーを公開します。

メソッド

	名前	形容
	Connect	監視可能なデータを接続します。
	サブスクライブ	(IObservable<T>から継承されます。

ページのトップへ

拡張メソッド

ページのトップへ

備考

コールド オブザーバブルはサブスクリプションで実行を開始します。つまり、監視可能なシーケンスは、Subscribe が呼び出されたときにオブザーバーに値をプッシュし始めるだけです。 値もサブスクライバー間で共有されません。 これは、サブスクリプションがアクティブである前でも既に値を生成しているマウス移動イベントやストック ティッカーなどのホットオブザーバとは異なります。 オブザーバーは、ホットな監視可能なシーケンスをサブスクライブすると、ストリーム内の現在の値を取得します。 ホット監視可能シーケンスはすべてのサブスクライバー間で共有され、各サブスクライバーはシーケンス内の次の値をプッシュされます。 たとえば、誰も特定の株式ティッカーをサブスクライブしていない場合でも、ティッカーは市場の動きに基づいて値を更新し続けます。 サブスクライバーがこのティッカーに関心を登録すると、自動的に最新のティックが取得されます。

例

次の例では、Publish 演算子を使用してコールド 監視可能なシーケンス ソースをホットなシーケンス ソースに変換します。この演算子は、ホットという名前のインスタンス> IConnectableObservable<T を返します。 Publish オペレーターは、1 つのサブスクリプションを複数のサブスクライバーにブロードキャストすることで、サブスクリプションを共有するメカニズムを提供します。 ホットはプロキシとして機能し、ソースをサブスクライブし、ソースから値を受け取ると、それらを独自のサブスクライバーにプッシュします。 バッキング ソースへのサブスクリプションを確立し、値の受信を開始するには、IConnectableObservable.Connect() メソッドを使用します。 IConnectableObservable は IObservable を継承するため、Subscribe を使用して、実行を開始する前でもこのホット シーケンスをサブスクライブできます。 この例では、subscription1 がサブスクライブするときにホット シーケンスが開始されていないことに注意してください。 そのため、値はサブスクライバーにプッシュされません。 Connect を呼び出すと、値が subscription1 にプッシュされます。 3 秒の遅延の後、subscription2 はホットにサブスクライブし、現在の位置 (この場合は 3) から最後まですぐに値の受信を開始します。 出力は次のようになります。

Current Time: 6/1/2011 3:38:49 PM

Current Time after 1st subscription: 6/1/2011 3:38:49 PM

Current Time after Connect: 6/1/2011 3:38:52 PM

Observer 1: OnNext: 0

Observer 1: OnNext: 1

Current Time just before 2nd subscription: 6/1/2011 3:38:55 PM 

Observer 1: OnNext: 2

Observer 1: OnNext: 3

Observer 2: OnNext: 3

Observer 1: OnNext: 4

Observer 2: OnNext: 4

       
Console.WriteLine("Current Time: " + DateTime.Now);
var source = Observable.Interval(TimeSpan.FromSeconds(1));   //creates a sequence

IConnectableObservable<long> hot = Observable.Publish<long>(source);  // convert the sequence into a hot sequence

IDisposable subscription1 = hot.Subscribe(     // no value is pushed to 1st subscription at this point
                            x => Console.WriteLine("Observer 1: OnNext: {0}", x),
                            ex => Console.WriteLine("Observer 1: OnError: {0}", ex.Message),
                            () => Console.WriteLine("Observer 1: OnCompleted"));
Console.WriteLine("Current Time after 1st subscription: " + DateTime.Now);
Thread.Sleep(3000);  //idle for 3 seconds
hot.Connect();       // hot is connected to source and starts pushing value to subscribers 
Console.WriteLine("Current Time after Connect: " + DateTime.Now);
Thread.Sleep(3000);  //idle for 3 seconds
Console.WriteLine("Current Time just before 2nd subscription: " + DateTime.Now);
IDisposable subscription2 = hot.Subscribe(     // value will immediately be pushed to 2nd subscription
                            x => Console.WriteLine("Observer 2: OnNext: {0}", x),
                            ex => Console.WriteLine("Observer 2: OnError: {0}", ex.Message),
                            () => Console.WriteLine("Observer 2: OnCompleted"));
Console.ReadKey();

関連項目

参考

System.Reactive.Subjects 名前空間の