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

[アーティクル]
06/28/2011

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

Namespace: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> 型は、次のメンバーを公開します。

メソッド

	名前	説明
	のインスタンスに接続するときには、	監視可能なを接続します。
	サブスクライブ	(IObservable から継承されます)<T>.)

上

拡張メソッド

	名前	説明
	集計<T>(Func<T, T, T>)	オーバーロードされます。監視可能なシーケンスにアキュムレータ関数を適用します。 ( Observable によって定義されます)。
	Aggregate<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>)	オーバーロードされます。指定されたシード値を持つ監視可能なシーケンスにアキュムレータ関数を適用します。 ( Observable によって定義されます)。
	すべての<T>	監視可能なシーケンスのすべての要素が条件を満たすかどうかを判断します。 ( Observable によって定義されます)。
	Amb<T>	指定した 1 番目と 2 番目のシーケンスと最初に反応する観測可能なシーケンスを伝達します。 ( Observable によって定義されます)。
	および<T、TRight>	両方の監視可能なシーケンスに使用可能な値がある場合に一致します。 ( Observable によって定義されます)。
	Any<T>()	オーバーロードされます。監視可能なシーケンスに要素が含まれているかどうかを判断します。 ( Observable によって定義されます)。
	Any<T>(Func<T, Boolean>)	オーバーロードされます。監視可能なシーケンスのすべての要素が条件を満たすかどうかを判断します。 ( Observable によって定義されます)。
	AsObservable<T>	監視可能なシーケンスの ID を非表示にします。 ( Observable によって定義されます)。
	AsQbservable<T>	監視可能なシーケンスをクエリ可能な監視可能なシーケンスに変換します。 ( Qbservable によって定義されます。
	AssertEqual<T>	( 拡張機能によって定義されます。)
	Buffer<T>(Int32)	オーバーロードされます。監視可能なシーケンスの各要素を、要素数情報に基づいて生成される連続した重複しないバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T>(TimeSpan)	オーバーロードされます。監視可能なシーケンスの各要素を、タイミング情報に基づいて生成される連続した重複しないバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T>(Int32, Int32)	オーバーロードされます。監視可能なシーケンスの各要素を、要素数情報に基づいて生成される 0 個以上のバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T>(TimeSpan, IScheduler)	オーバーロードされます。監視可能なシーケンスの各要素を、タイミング情報に基づいて生成される連続した重複しないバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T>(TimeSpan, TimeSpan)	オーバーロードされます。監視可能なシーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T>(TimeSpan, Int32)	オーバーロードされます。監視可能なシーケンスの各要素をバッファーに示します。バッファーが満杯になった場合、または特定の時間が経過した場合に送信されます。 ( Observable によって定義されます)。
	Buffer<T>(TimeSpan, TimeSpan, IScheduler)	オーバーロードされます。監視可能なシーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T>(TimeSpan, Int32, IScheduler)	オーバーロードされます。監視可能なシーケンスの各要素をバッファーに示します。バッファーが満杯になった場合、または特定の時間が経過した場合に送信されます。 ( Observable によって定義されます)。
	バッファー<T、TBufferClosing>(Func<IObservable<TBufferClosing>>)	オーバーロードされます。観測可能なシーケンスの各要素を連続する重複しないバッファーに示します。 ( Observable によって定義されます)。
	Buffer<T, TBufferOpening, TBufferClosing>(IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>)	オーバーロードされます。クエリ可能な監視可能シーケンスの各要素を連続する重複しないバッファーに示します。 ( Observable によって定義されます)。
	Catch<T>(IObservable<T>)	オーバーロードされます。次の監視可能シーケンスを使用して、例外によって終了される監視可能なシーケンスを続行します。 ( Observable によって定義されます)。
	Catch<T, TException>(Func<TException, IObservable<T>>)	オーバーロードされます。ハンドラーによって生成された監視可能なシーケンスを使用して、指定された型の例外によって終了される監視可能なシーケンスを続行します。 ( Observable によって定義されます)。
	CombineLatest<T、TSecond、TResult>	監視可能シーケンスの 1 つが要素を生成するたびにセレクター関数を使用して、2 つの監視可能なシーケンスを 1 つの監視可能なシーケンスにマージします。 ( Observable によって定義されます)。
	Concat<T>	2 つの監視可能なシーケンスを連結します。 ( Observable によって定義されます)。
	T>(T) を<含む	オーバーロードされます。既定の等値比較子を使用して、監視可能なシーケンスに指定された要素が含まれているかどうかを判断します。 ( Observable によって定義されます)。
	<T>(T, IEqualityComparer<T>) を含む	オーバーロードされます。指定した System.Collections.Generic.IEqualityComparer&lt を使用して、監視可能なシーケンスに指定された要素が含まれているかどうかを判断します。T>. ( Observable によって定義されます)。
	カウント<T>	監視可能なシーケンス内の要素の合計数を表す Int32 を返します。 ( Observable によって定義されます)。
	DefaultIfEmpty<T>()	オーバーロードされます。シーケンスが空の場合は、指定したシーケンスの要素、またはシングルトンシーケンス内の型パラメーターの既定値を返します。 ( Observable によって定義されます)。
	DefaultIfEmpty<T>(T)	オーバーロードされます。シーケンスが空の場合は、指定したシーケンスの要素、またはシングルトンシーケンス内の型パラメーターの既定値を返します。 ( Observable によって定義されます)。
	Delay<T>(TimeSpan)	オーバーロードされます。指定した source と dueTime の期限で監視可能なシーケンスを示します。 ( Observable によって定義されます)。
	Delay<T>(DateTimeOffset)	オーバーロードされます。指定した source と dueTime の期限で監視可能なシーケンスを示します。 ( Observable によって定義されます)。
	Delay<T>(TimeSpan, IScheduler)	オーバーロードされます。指定したソース、dueTime、およびスケジューラを使用して、期限で監視可能なシーケンスを示します。 ( Observable によって定義されます)。
	Delay<T>(DateTimeOffset, IScheduler)	オーバーロードされます。指定したソース、dueTime、およびスケジューラを使用して、期限で監視可能なシーケンスを示します。 ( Observable によって定義されます)。
	Distinct<T>()	オーバーロードされます。指定したソースを持つ個別の要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます)。
	Distinct<T>(IEqualityComparer<T>)	オーバーロードされます。比較子に従って、個別の要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます)。
	Distinct<T、TKey>(Func<T、TKey>)	オーバーロードされます。 keySelector に従って、個別の要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます)。
	Distinct<T,TKey>(Func<T, TKey>, IEqualityComparer<TKey>)	オーバーロードされます。 keySelector に従って、個別の要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます。
	DistinctUntilChanged<T>()	オーバーロードされます。指定したソースを持つ個別の連続する要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます。
	DistinctUntilChanged<T>(IEqualityComparer<T>)	オーバーロードされます。比較子に従って個別の連続する要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます。
	DistinctUntilChanged<T,TKey>(Func<T, TKey>)	オーバーロードされます。 keySelector に従って、個別の連続する要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます。
	DistinctUntilChanged<T,TKey>(Func<T, TKey>, IEqualityComparer<TKey>)	オーバーロードされます。 keySelector と比較子に従って、個別の連続する要素のみを含む監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Do<T>(Action<T>)	オーバーロードされます。監視可能なシーケンス内の各要素に対してアクションを呼び出します。 ( Observable によって定義されます。
	Do<T>(IObserver<T>)	オーバーロードされます。監視可能シーケンス内の各要素に対してアクションを呼び出し、監視可能シーケンスの例外的な終了時にアクションを呼び出します。 ( Observable によって定義されます。
	Do<T>(Action<T>, Action)	オーバーロードされます。監視可能なシーケンス内の各要素に対してアクションを呼び出し、監視可能なシーケンスの正常な終了時にアクションを呼び出します。 ( Observable によって定義されます。
	Do<T>(Action<T>, Action<Exception>)	オーバーロードされます。監視可能シーケンス内の各要素に対してアクションを呼び出し、監視可能シーケンスの例外的な終了時にアクションを呼び出します。 ( Observable によって定義されます。
	Do<T>(Action<T>, Action<Exception>, Action)	オーバーロードされます。監視可能なシーケンス内の各要素に対してアクションを呼び出し、監視可能なシーケンスの正常または例外的な終了時にアクションを呼び出します。 ( Observable によって定義されます。
	ElementAt<T>	シーケンス内の指定されたインデックス位置にある要素を返します。 ( Observable によって定義されます。
	ElementAtOrDefault<T>	シーケンス内の指定したインデックス位置にある要素を返します。インデックスが範囲外の場合は既定値を返します。 ( Observable によって定義されます。
	Finally<T>	ソース監視可能シーケンスが正常に終了した後、または例外によって、指定されたアクションを呼び出します。 ( Observable によって定義されます。
	最初の<T>()	オーバーロードされます。指定したソースを持つ監視可能なシーケンスの最初の要素を返します。 ( Observable によって定義されます。
	First<T>(Func<T, Boolean>)	オーバーロードされます。述語に一致する監視可能なシーケンスの最初の要素を返します。 ( Observable によって定義されます。
	FirstOrDefault<T>()	オーバーロードされます。監視可能なシーケンスの最初の要素を返します。値が見つからない場合は既定値を返します。 ( Observable によって定義されます。
	FirstOrDefault<T>(Func<T, Boolean>)	オーバーロードされます。述語に一致する監視可能なシーケンスの最初の要素を返します。値が見つからない場合は既定値を返します。 ( Observable によって定義されます。
	Foo<T、R>	( MyExt によって定義されます。)
	ForEach<T>	監視可能なシーケンス内の各要素に対してアクションを呼び出し、シーケンスが終了するまでブロックします。 ( Observable によって定義されます。
	GetEnumerator<T>	監視可能なシーケンスのすべての値を列挙する列挙子を返します。 ( Observable によって定義されます。
	GroupBy<T,TKey>(Func<T, TKey>)	オーバーロードされます。指定したキーセレクター関数に従って、監視可能なシーケンスの要素をグループ化します。 ( Observable によって定義されます。
	GroupBy<T,TKey>(Func<T, TKey>, IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数と比較子に従って、監視可能なシーケンスの要素をグループ化します。 ( Observable によって定義されます。
	GroupBy<T、TKey、TElement>(Func<T、TKey>、Func<T、TElement>)	オーバーロードされます。監視可能なシーケンスの要素をグループ化し、指定した関数を使用して結果の要素を選択します。 ( Observable によって定義されます。
	GroupBy<T、TKey、TElement>(Func<T、TKey>、Func<T、TElement>、IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数と比較子に従って監視可能なシーケンスの要素をグループ化し、指定した関数を使用して結果の要素を選択します。 ( Observable によって定義されます。
	GroupByUntil<T,TKey, TDuration>(Func<T, TKey>, Func<IGroupedObservable<TKey, T>, IObservable<TDuration>>)	オーバーロードされます。指定したキーセレクター関数に従って、監視可能なシーケンスの要素をグループ化します。 ( Observable によって定義されます。
	GroupByUntil<T、TKey、TDuration>(Func<T、TKey>、Func<IGroupedObservable<TKey、T>、IObservable<TDuration>>、IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数と比較子に従って、監視可能なシーケンスの要素をグループ化します。 ( Observable によって定義されます。
	GroupByUntil<T、TKey、TElement、TDuration>(Func<T、TKey>、Func<T、TElement>、Func<IGroupedObservable<TKey、TElement>、IObservable<TDuration>>)	オーバーロードされます。指定したキーセレクター関数に従って監視可能なシーケンスの要素をグループ化し、指定した関数を使用して結果の要素を選択します。 ( Observable によって定義されます。
	GroupByUntil<T、TKey、TElement、TDuration>(Func<T、TKey>、Func<T、TElement>、Func<IGroupedObservable<TKey、TElement>、IObservable<TDuration>>、IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数と比較子に従って監視可能なシーケンスの要素をグループ化し、指定した関数を使用して結果の要素を選択します。 ( Observable によって定義されます。
	GroupJoin<T、TRight、TLeftDuration、TRightDuration、TResult>	重複する期間に基づいて 2 つのシーケンスの要素を関連付け、結果をグループ化します。 ( Observable によって定義されます。
	IgnoreElements<T>	終了メッセージのみを残したまま、監視可能なシーケンス内のすべての値を無視します。 ( Observable によって定義されます。
	結合<T、TRight、TLeftDuration、TRightDuration、TResult>	重複する期間に基づいて、2 つのシーケンスの要素を関連付けます。 ( Observable によって定義されます。
	Last<T>()	オーバーロードされます。指定したソースを持つ監視可能なシーケンスの最後の要素を返します。 ( Observable によって定義されます。
	Last<T>(Func<T, Boolean>)	オーバーロードされます。述語に一致する監視可能なシーケンスの最後の要素を返します。 ( Observable によって定義されます。
	LastOrDefault<T>()	オーバーロードされます。監視可能なシーケンス内の最後の要素を返します。値が見つからない場合は既定値を返します。 ( Observable によって定義されます。
	LastOrDefault<T>(Func<T, Boolean>)	オーバーロードされます。述語に一致する監視可能なシーケンスの最後の要素を返します。値が見つからない場合は既定値を返します。 ( Observable によって定義されます。
	最新<の T>	監視可能なシーケンス内の最新の値をサンプリングします。 ( Observable によって定義されます。
	LongCount<T>	監視可能なシーケンス内の要素の合計数を表す Int64 を返します。 ( Observable によって定義されます。
	<具体化 T>	監視可能なシーケンスの暗黙的な通知を明示的な通知値として具体化します。 ( Observable によって定義されます。
	最大<T>()	オーバーロードされます。監視可能なシーケンス内の最大要素を返します。 ( Observable によって定義されます。
	最大<T>(IComparer<T>)	オーバーロードされます。指定した比較子に従って、監視可能なシーケンスの最大値を返します。 ( Observable によって定義されます。
	MaxBy<T、TKey>(Func<T、TKey>)	オーバーロードされます。最大キー値を持つ監視可能なシーケンス内の要素を返します。 ( Observable によって定義されます。
	MaxBy<T、TKey>(Func<T、TKey>、IComparer<TKey>)	オーバーロードされます。最大キー値を持つ監視可能なシーケンス内の要素を返します。 ( Observable によって定義されます。
	マージ<T>(IObservable<T>)	オーバーロードされます。監視可能なシーケンスの監視可能なシーケンスを監視可能なシーケンスにマージします。 ( Observable によって定義されます。
	Merge<T>(IObservable<T>, IScheduler)	オーバーロードされます。 2 つの監視可能なシーケンスを 1 つの監視可能なシーケンスにマージします。 ( Observable によって定義されます。
	Min<T>()	オーバーロードされます。監視可能なシーケンス内の最小要素を返します。 ( Observable によって定義されます。
	Min<T>(IComparer<T>)	オーバーロードされます。指定した比較子に従って、監視可能なシーケンスの最小値を返します。 ( Observable によって定義されます。
	MinBy<T、TKey>(Func<T、TKey>)	オーバーロードされます。最小キー値を持つ監視可能なシーケンス内の要素を返します。 ( Observable によって定義されます。
	MinBy<T、TKey>(Func<T、TKey>、IComparer<TKey>)	オーバーロードされます。指定した比較子に従って、最小キー値を持つ監視可能なシーケンス内の要素を返します。 ( Observable によって定義されます。
	MostRecent<T>	監視可能なシーケンス内の最新の値をサンプリングします。 ( Observable によって定義されます。
	Multicast<T, TResult>(ISubject<T, TResult>)	オーバーロードされます。接続時にソースシーケンスが指定したサブジェクトに結果をプッシュする、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	マルチキャスト<T、TIntermediate、TResult>(Func<ISubject<T、TIntermediate>>、Func<IObservable<TIntermediate>、IObservable<TResult>>)	オーバーロードされます。セレクター関数内でソースシーケンスをマルチキャストすることによって生成されるシーケンスの要素を含む監視可能なシーケンスを返します。 ( Observable によって定義されます。
	次の<T>	監視可能なシーケンス内のから、次の値 (バッファリングなしでブロック) をサンプリングします。 ( Observable によって定義されます。
	ObserveOn<T>(SynchronizationContext)	オーバーロードされます。指定した同期コンテキストでオブザーバーに非同期的に通知します。 ( Observable によって定義されます。
	ObserveOn<T>(Control)	オーバーロードされます。 ( ControlObservable によって定義されます。
	ObserveOn<T>(Dispatcher)	オーバーロードされます。 ( DispatcherObservable によって定義されます)。
	ObserveOn<T>(DispatcherScheduler)	オーバーロードされます。 ( DispatcherObservable によって定義されます)。
	ObserveOn<T>(IScheduler)	オーバーロードされます。指定したスケジューラでオブザーバーに非同期的に通知します。 ( Observable によって定義されます。
	ObserveOnDispatcher<T>	( DispatcherObservable によって定義されます)。
	OnErrorResumeNext<T>	正常に終了するか、次の監視可能なシーケンスで例外によって終了される監視可能なシーケンスを続行します。 ( Observable によって定義されます。
	発行<T>()	オーバーロードされます。基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	発行<T>(T)	オーバーロードされます。基になるシーケンスに 1 つのサブスクリプションを共有し、initialValue で始まる、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Publish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>)	オーバーロードされます。基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Publish<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T)	オーバーロードされます。基になるシーケンスに 1 つのサブスクリプションを共有し、initialValue で始まる、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	PublishLast<T>()	オーバーロードされます。最後の通知のみを含む基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	PublishLast<T, TResult>(Func<IObservable<T>, IObservable<TResult>>)	オーバーロードされます。最後の通知のみを含む基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	RefCount<TSource>	監視可能なシーケンスに少なくとも 1 つのサブスクリプションがある限り、ソースに接続された状態を維持する監視可能なシーケンスを返します。 ( Observable によって定義されます。
	繰り返し<T>()	オーバーロードされます。監視可能なシーケンスを無期限に繰り返します。 ( Observable によって定義されます。
	繰り返し<T>(Int32)	オーバーロードされます。監視可能なシーケンスを無期限に繰り返します。 ( Observable によって定義されます。
	再生<T>()	オーバーロードされます。すべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	再生<T>(TimeSpan)	オーバーロードされます。ウィンドウ内のすべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	再生<T>(Int32)	オーバーロードされます。 bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T>(IScheduler)	オーバーロードされます。すべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T>(TimeSpan, IScheduler)	オーバーロードされます。ウィンドウ内のすべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T>(Int32, IScheduler)	オーバーロードされます。 bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	再生<T>(Int32, TimeSpan)	オーバーロードされます。ウィンドウ内の bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T>(Int32, TimeSpan, IScheduler)	オーバーロードされます。ウィンドウ内の bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>)	オーバーロードされます。基になるシーケンスに 1 つのサブスクリプションを共有し、初期値で始まる、接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, IScheduler)	オーバーロードされます。すべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan)	オーバーロードされます。ウィンドウ内のすべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32)	オーバーロードされます。 bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan, IScheduler)	オーバーロードされます。ウィンドウ内のすべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, IScheduler)	オーバーロードされます。 bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan)	オーバーロードされます。ウィンドウ内の bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan, IScheduler)	オーバーロードされます。ウィンドウ内の bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する接続可能な監視可能なシーケンスでセレクターを呼び出した結果である監視可能なシーケンスを返します。 ( Observable によって定義されます。
	再試行<T>()	オーバーロードされます。ソースの監視可能なシーケンスが正常に終了するまで繰り返します。 ( Observable によって定義されます。
	再試行<T>(Int32)	オーバーロードされます。ソース監視可能シーケンスが正常に終了するまで繰り返します。 ( Observable によって定義されます)。
	サンプル<T>(TimeSpan)	オーバーロードされます。観測可能なシーケンスを各間隔でサンプリングします。 ( Observable によって定義されます)。
	サンプル<T>(TimeSpan, IScheduler)	オーバーロードされます。指定したソース、間隔、スケジューラを使用して、各間隔で監視可能なシーケンスをサンプリングします。 ( Observable によって定義されます)。
	サンプル<T、TSample>(IObservable<TSample>)	オーバーロードされます。指定したソースとサンプラーを使用して、サンプリングティックで監視可能なシーケンスをサンプリングします。 ( Observable によって定義されます)。
	スキャン<T>(Func<T, T, T>)	オーバーロードされます。監視可能なシーケンスにアキュムレータ関数を適用し、指定されたソースとアキュムレータを使用して各中間結果を返します。 ( Observable によって定義されます)。
	スキャン<T、TAccumulate>(TAccumulate、Func<TAccumulate、T、TAccumulate>)	オーバーロードされます。監視可能なシーケンスにアキュムレータ関数を適用し、指定されたソース、シード、アキュムレータを使用して各中間結果を返します。 ( Observable によって定義されます)。
	T、TResult(Func<T、TResult>) を選択<します>	オーバーロードされます。監視可能なシーケンスの各要素を、指定したソースとセレクターを使用して新しいフォームに投影します。 ( Observable によって定義されます)。
	T、TResult(Func<T、Int32、TResult>) を選択<します>	オーバーロードされます。指定したソースとセレクターに要素のインデックスを組み込むことで、監視可能なシーケンスの各要素を新しいフォームに投影します。 ( Observable によって定義されます)。
	SelectMany<T, TOther>(IObservable<TOther>)	オーバーロードされます。監視可能シーケンスの各要素を監視可能なシーケンスに投影し、結果の観測可能なシーケンスを 1 つの観測可能なシーケンスにフラット化します。 ( Observable によって定義されます)。
	SelectMany<T, TResult>(Func<T, IObservable<TResult>>)	オーバーロードされます。監視可能シーケンスの各要素を監視可能なシーケンスに投影し、結果の観測可能なシーケンスを 1 つの観測可能なシーケンスにフラット化します。 ( Observable によって定義されます)。
	SelectMany<T, TResult>(Func<T, IEnumerable<TResult>>)	オーバーロードされます。監視可能シーケンスの各要素を監視可能なシーケンスに投影し、結果の観測可能なシーケンスを 1 つの観測可能なシーケンスにフラット化します。 ( Observable によって定義されます)。
	SelectMany<T, TResult>(Func<T, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>)	オーバーロードされます。監視可能シーケンスの各要素を監視可能なシーケンスに投影し、結果の観測可能なシーケンスを 1 つの観測可能なシーケンスにフラット化します。 ( Observable によって定義されます)。
	SelectMany<T,TCollection, TResult>(Func<T, IEnumerable<TCollection>>, Func<T, TCollection, TResult>)	オーバーロードされます。監視可能シーケンスの各要素を監視可能なシーケンスに投影し、結果の観測可能なシーケンスを 1 つの観測可能なシーケンスにフラット化します。 ( Observable によって定義されます)。
	SelectMany<T,TCollection, TResult>(Func<T, IObservable<TCollection>>, Func<T, TCollection, TResult>)	オーバーロードされます。監視可能シーケンスの各要素を監視可能なシーケンスに投影し、結果の観測可能なシーケンスを 1 つの観測可能なシーケンスにフラット化します。 ( Observable によって定義されます)。
	SequenceEqual<T>(IObservable<T>)	オーバーロードされます。要素をペアで比較して、2 つのシーケンスが等しいかどうかを判断します。 ( Observable によって定義されます)。
	SequenceEqual<T>(IObservable<T>, IEqualityComparer<T>)	オーバーロードされます。指定した等値比較子を使用して要素をペアで比較することで、2 つのシーケンスが等しいかどうかを判断します。 ( Observable によって定義されます)。
	単一<T>()	オーバーロードされます。監視可能シーケンスの唯一の要素を返し、監視可能なシーケンスに要素が 1 つだけ存在しない場合は例外をスローします。 ( Observable によって定義されます)。
	単一<T>(Func<T, Boolean>)	オーバーロードされます。述語に一致する監視可能なシーケンスの唯一の要素を返し、監視可能シーケンスに要素が 1 つも存在しない場合は例外をスローします。 ( Observable によって定義されます)。
	SingleOrDefault<T>()	オーバーロードされます。監視可能シーケンスの唯一の要素を返します。監視可能なシーケンスが空の場合は既定値を返します。 ( Observable によって定義されます)。
	SingleOrDefault<T>(Func<T, Boolean>)	オーバーロードされます。述語に一致する監視可能なシーケンスの唯一の要素を返します。値が見つからない場合は既定値を返します。 ( Observable によって定義されます)。
	スキップ<T>	監視可能なシーケンス内の指定された数の値をバイパスし、残りの値を返します。 ( Observable によって定義されます)。
	SkipLast<T>	監視可能なシーケンスの末尾で、指定された数の要素をバイパスします。 ( Observable によって定義されます)。
	SkipUntil<T、TOther>	他の監視可能シーケンスが値を生成した後にのみ、ソース監視可能シーケンスから値を返します。 ( Observable によって定義されます)。
	SkipWhile<T>(Func<T, Boolean>)	オーバーロードされます。指定した条件が true である限り、監視可能なシーケンス内の値をバイパスし、残りの値を返します。 ( Observable によって定義されます)。
	SkipWhile<T>(Func<T, Int32, Boolean>)	オーバーロードされます。指定した条件が true である限り、監視可能なシーケンス内の値をバイパスし、残りの値を返します。 ( Observable によって定義されます)。
	StartWith<T>T[])	オーバーロードされます。指定したソースと値を使用して、監視可能なシーケンスに値のシーケンスを付加します。 ( Observable によって定義されます)。
	StartWith<T>(IScheduler, T[])	オーバーロードされます。指定したソース、スケジューラ、値を使用して、監視可能なシーケンスに値のシーケンスを付加します。 ( Observable によって定義されます)。
	Subscribe<T>()	オーバーロードされます。指定したソースを使用して監視可能なシーケンスを評価します。 ( ObservableExtensions によって定義されます)。
	サブスクライブ<T>(アクション<T>)	オーバーロードされます。監視可能なシーケンスに要素ハンドラーをサブスクライブします。 ( ObservableExtensions によって定義されます)。
	Subscribe<T>(Action<T>, Action<Exception>)	オーバーロードされます。要素ハンドラーと例外ハンドラーを監視可能なシーケンスにサブスクライブします。 ( ObservableExtensions によって定義されます)。
	サブスクライブ<T>(Action<T>, Action)	オーバーロードされます。要素ハンドラーと完了ハンドラーを監視可能なシーケンスにサブスクライブします。 ( ObservableExtensions によって定義されます)。
	Subscribe<T>(Action<T>, Action<Exception>, Action)	オーバーロードされます。要素ハンドラー、例外ハンドラー、および完了ハンドラーを監視可能なシーケンスにサブスクライブします。 ( ObservableExtensions によって定義されます)。
	SubscribeOn<T>(SynchronizationContext)	オーバーロードされます。指定した同期コンテキストでオブザーバーを非同期的にサブスクライブおよびサブスクライブ解除します。 ( Observable によって定義されます)。
	SubscribeOn<T>(Control)	オーバーロードされます。 ( ControlObservable によって定義されます。
	SubscribeOn<T>(Dispatcher)	オーバーロードされます。 ( DispatcherObservable によって定義されます。
	SubscribeOn<T>(DispatcherScheduler)	オーバーロードされます。 ( DispatcherObservable によって定義されます。
	SubscribeOn<T>(IScheduler)	オーバーロードされます。指定したスケジューラでオブザーバーを非同期的にサブスクライブおよびサブスクライブ解除します。 ( Observable によって定義されます)。
	SubscribeOnDispatcher<T>	( DispatcherObservable によって定義されます。
	同期<T>()	オーバーロードされます。監視可能なシーケンスを同期します。 ( Observable によって定義されます)。
	Synchronize<T>(Object)	オーバーロードされます。監視可能なシーケンスを同期します。 ( Observable によって定義されます)。
	Take<T>	監視可能なシーケンスの先頭から、指定した数の連続した値を返します。 ( Observable によって定義されます)。
	TakeLast<T>	監視可能なシーケンスの末尾から、指定した数の連続した要素を返します。 ( Observable によって定義されます)。
	TakeUntil<T、TOther>	他の監視可能なシーケンスが値を生成するまで、ソースの監視可能なシーケンスから値を返します。 ( Observable によって定義されます。
	TakeWhile<T>(Func<T, Boolean>)	オーバーロードされます。指定した条件が true である限り、監視可能なシーケンスから値を返し、残りの値をスキップします。 ( Observable によって定義されます。
	TakeWhile<T>(Func<T, Int32, Boolean>)	オーバーロードされます。指定した条件が true である限り、監視可能なシーケンスから値を返し、残りの値をスキップします。 ( Observable によって定義されます。
	次に<、T、TResult>	監視可能なシーケンスに使用可能な値があり、その値を投影する場合に一致します。 ( Observable によって定義されます。
	スロットル<T>(TimeSpan)	オーバーロードされます。指定した source と dueTime で期限前に別の値が続く、監視可能なシーケンスの値を無視します。 ( Observable によって定義されます。
	スロットル<T>(TimeSpan, IScheduler)	オーバーロードされます。指定したソース、dueTime、およびスケジューラを使用して、期限前に別の値が続く監視可能なシーケンスの値を無視します。 ( Observable によって定義されます。
	TimeInterval<T>()	オーバーロードされます。指定したソースを持つ監視可能なシーケンス内の連続する値間の時間間隔を記録します。 ( Observable によって定義されます。
	TimeInterval<T>(IScheduler)	オーバーロードされます。指定したソースとスケジューラを使用して、監視可能なシーケンス内の連続する値間の時間間隔を記録します。 ( Observable によって定義されます。
	Timeout<T>(TimeSpan)	オーバーロードされます。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException を返します。 ( Observable によって定義されます。
	Timeout<T>(DateTimeOffset)	オーバーロードされます。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException を返します。 ( Observable によって定義されます。
	Timeout<T>(TimeSpan, IObservable<T>)	オーバーロードされます。 dueTime が経過した場合は、ソースの監視可能なシーケンスまたは他の監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Timeout<T>(DateTimeOffset, IObservable<T>)	オーバーロードされます。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException を返します。 ( Observable によって定義されます。
	Timeout<T>(TimeSpan, IScheduler)	オーバーロードされます。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException を返します。 ( Observable によって定義されます。
	Timeout<T>(DateTimeOffset, IScheduler)	オーバーロードされます。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException を返します。 ( Observable によって定義されます。
	Timeout<T>(TimeSpan, IObservable<T>, IScheduler)	オーバーロードされます。 dueTime が経過した場合は、ソースの監視可能なシーケンスまたは他の監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Timeout<T>(DateTimeOffset, IObservable<T>, IScheduler)	オーバーロードされます。 dueTime が経過した場合は、ソースの監視可能なシーケンスまたは他の監視可能なシーケンスを返します。 ( Observable によって定義されます。
	Timestamp<T>()	オーバーロードされます。指定されたソースを持つ監視可能なシーケンス内の各値のタイムスタンプを記録します。 ( Observable によって定義されます。
	Timestamp<T>(IScheduler)	オーバーロードされます。指定したソースとスケジューラを使用して、監視可能なシーケンス内の各値のタイムスタンプを記録します。 ( Observable によって定義されます。
	ToArray<T>	監視可能なシーケンスから配列を作成します。 ( Observable によって定義されます。
	ToDictionary<T,TKey>(Func<T, TKey>)	オーバーロードされます。指定したキーセレクター関数に従って、監視可能なシーケンスからディクショナリを作成します。 ( Observable によって定義されます。
	ToDictionary<T,TKey>(Func<T, TKey>, IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数と比較子に従って、監視可能なシーケンスからディクショナリを作成します。 ( Observable によって定義されます)。
	ToDictionary<T、TKey、TElement>(Func<T、TKey>、Func<T、TElement>)	オーバーロードされます。指定したキーセレクター関数と要素セレクター関数に従って、監視可能なシーケンスからディクショナリを作成します。 ( Observable によって定義されます)。
	ToDictionary<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>, IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数、比較子、および要素セレクター関数に従って、監視可能なシーケンスからディクショナリを作成します。 ( Observable によって定義されます)。
	ToEnumerable<T>	監視可能なシーケンスを列挙可能なシーケンスに変換します。 ( Observable によって定義されます)。
	ToEvent<T>	指定したソースを持つ .NET イベントを持つオブジェクトとして、監視可能なシーケンスを公開します。 ( Observable によって定義されます)。
	ToList<T>	監視可能なシーケンスからリストを作成します。 ( Observable によって定義されます)。
	ToLookup<T,TKey>(Func<T, TKey>)	オーバーロードされます。指定したキーセレクター関数に従って、監視可能なシーケンスから参照を作成します。 ( Observable によって定義されます)。
	ToLookup<T,TKey>(Func<T, TKey>, IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数と比較子に従って、監視可能なシーケンスからルックアップを作成します。 ( Observable によって定義されます)。
	ToLookup<T、TKey、TElement>(Func<T、TKey>、Func<T、TElement>)	オーバーロードされます。指定したキーセレクター関数と要素セレクター関数に従って、監視可能なシーケンスから参照を作成します。 ( Observable によって定義されます)。
	ToLookup<T、TKey、TElement>(Func<T、TKey>、Func<T、TElement>、IEqualityComparer<TKey>)	オーバーロードされます。指定したキーセレクター関数、比較子、および要素セレクター関数に従って、監視可能なシーケンスから参照を作成します。 ( Observable によって定義されます)。
	ToTask<T>()	オーバーロードされます。監視可能シーケンスの最後の値を含むタスクを返します。 ( TaskObservableExtensions によって定義されます)。
	ToTask<T>(Object)	オーバーロードされます。監視可能シーケンスの最後の値を含むタスクを返します。 ( TaskObservableExtensions によって定義されます)。
	ToTask<T>(CancellationToken)	オーバーロードされます。監視可能シーケンスの最後の値を含むタスクを返します。 ( TaskObservableExtensions によって定義されます)。
	ToTask<T>(CancellationToken, Object)	オーバーロードされます。監視可能シーケンスの最後の値を含むタスクを返します。 ( TaskObservableExtensions によって定義されます)。
	Where<T>(Func<T, Boolean>)	オーバーロードされます。述語に基づいて監視可能なシーケンスの要素をフィルター処理します。 ( Observable によって定義されます)。
	Where<T>(Func<T, Int32, Boolean>)	オーバーロードされます。要素のインデックスを組み込むことによって、述語に基づいて監視可能なシーケンスの要素をフィルター処理します。 ( Observable によって定義されます)。
	Window<T>(Int32)	オーバーロードされます。監視可能シーケンスの各要素を、要素数情報に基づいて生成される連続した重複しないウィンドウに投影します。 ( Observable によって定義されます)。
	ウィンドウ<T>(TimeSpan)	オーバーロードされます。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される連続した重複しないウィンドウに投影します。 ( Observable によって定義されます)。
	Window<T>(Int32, Int32)	オーバーロードされます。監視可能なシーケンスの各要素を、要素数情報に基づいて生成される 0 個以上のウィンドウに投影します。 ( Observable によって定義されます)。
	Window<T>(TimeSpan, IScheduler)	オーバーロードされます。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される連続した重複しないウィンドウに投影します。 ( Observable によって定義されます)。
	Window<T>(TimeSpan, TimeSpan)	オーバーロードされます。監視可能なシーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のウィンドウに投影します。 ( Observable によって定義されます)。
	Window<T>(TimeSpan, Int32)	オーバーロードされます。監視可能なシーケンスの各要素を、満杯になった場合または特定の時間が経過したときに完了したウィンドウに投影します。 ( Observable によって定義されます)。
	Window<T>(TimeSpan, TimeSpan, IScheduler)	オーバーロードされます。監視可能なシーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のウィンドウに投影します。 ( Observable によって定義されます)。
	Window<T>(TimeSpan, Int32, IScheduler)	オーバーロードされます。監視可能なシーケンスの各要素を、満杯になった場合または特定の時間が経過したときに完了したウィンドウに投影します。 ( Observable によって定義されます)。
	ウィンドウ<T、TWindowClosing>(Func<IObservable<TWindowClosing>>)	オーバーロードされます。監視可能なシーケンスの各要素を連続する重複しないウィンドウに投影します。 ( Observable によって定義されます)。
	ウィンドウ<T、TWindowOpening、TWindowClosing>(IObservable<TWindowOpening>、Func<TWindowOpening、IObservable<TWindowClosing>>)	オーバーロードされます。監視可能なシーケンスの各要素を 0 個以上のウィンドウに投影します。 ( Observable によって定義されます)。
	Zip<T、TSecond、TResult>(IObservable<TSecond>、Func<T、TSecond、TResult>)	オーバーロードされます。 2 つの観測可能なシーケンスを、ペアごとの方法で要素を組み合わせて、1 つの観測可能なシーケンスにマージします。 ( Observable によって定義されます)。
	Zip<T、TSecond、TResult>(IEnumerable<TSecond>、Func<T、TSecond、TResult>)	オーバーロードされます。セレクター関数を使用して、監視可能なシーケンスと列挙可能なシーケンスを 1 つの監視可能なシーケンスにマージします。 ( Observable によって定義されます)。

上

解説

コールドオブザーバブルはサブスクリプションで実行を開始します。つまり、監視可能なシーケンスは、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 名前空間

次の方法で共有

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

構文

型パラメーター

メソッド

拡張メソッド

解説

例

参照

リファレンス

その他のリソース