Subject<T> クラス

2011-06-28

観測可能なシーケンスとオブザーバーの両方であるオブジェクトを表します。

継承階層

System.Object
System.Reactive.Subjects.Subject<T>

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

構文

'Declaration
Public NotInheritable Class Subject(Of T) _
    Implements ISubject(Of T), ISubject(Of T, T),  _
    IObserver(Of T), IObservable(Of T), IDisposable

'Usage
Dim instance As Subject(Of T)

public sealed class Subject<T> : ISubject<T>, 
    ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable

generic<typename T>
public ref class Subject sealed : ISubject<T>, 
    ISubject<T, T>, IObserver<T>, IObservable<T>, IDisposable

[<SealedAttribute>]
type Subject<'T> =  
    class
        interface ISubject<'T>
        interface ISubject<'T, 'T>
        interface IObserver<'T>
        interface IObservable<'T>
        interface IDisposable
    end

JScript does not support generic types and methods.

型パラメーター

T
型。

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

コンストラクター

	名前	形容
	サブジェクト<T>	Subject<T> クラスの新しいインスタンスを初期化します。

ページのトップへ

メソッド

	名前	形容
	Dispose	Subject<T> クラスの現在のインスタンスで使用されているすべてのリソースを解放し、すべてのオブザーバーの登録を解除します
	Equals	(オブジェクトから継承されます。
	Finalize	(オブジェクトから継承されます。
	GetHashCode をする	(オブジェクトから継承されます。
	GetType をする	(オブジェクトから継承されます。
	MemberwiseClone	(オブジェクトから継承されます。
	OnCompleted	サブスクライブされているすべてのオブザーバーにシーケンスの末尾を通知します。
	OnError	サブスクライブされているすべてのオブザーバーに例外を通知します。
	OnNext	サブスクライブされているすべてのオブザーバーに値を通知します。
	サブスクライブ	オブザーバーを件名にサブスクライブします。
	ToString をする	(オブジェクトから継承されます。

ページのトップへ

拡張メソッド

	名前	形容
パブリック拡張メソッドパブリック拡張メソッド	集計<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	任意のT() をする	オーバーロード。監視可能なシーケンスに要素が含まれているかどうかを判断します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	任意の<T>(Func<T、Boolean>) を	オーバーロード。監視可能なシーケンスのすべての要素が条件を満たすかどうかを判断します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	AsObservable<T>	監視可能なシーケンスの ID を非表示にします。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	AsObserver<T>	オブザーバーの ID を非表示にします。 (オブザーバーによって定義。
パブリック拡張メソッドパブリック拡張メソッド	AsQbservableT をする	監視可能なシーケンスをクエリ可能な監視可能なシーケンスに変換します。 (Qbservableによって定義。
パブリック拡張メソッドパブリック拡張メソッド	AssertEqualT の	(Extensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(Int32)	オーバーロード。監視可能シーケンスの各要素を、要素数情報に基づいて生成される連続する重複しないバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(TimeSpan)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される連続する重複しないバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(Int32、Int32)	オーバーロード。監視可能シーケンスの各要素を、要素数情報に基づいて生成される 0 個以上のバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(TimeSpan、IScheduler)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される連続する重複しないバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(TimeSpan、TimeSpan)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(TimeSpan、Int32)	オーバーロード。監視可能なシーケンスの各要素をバッファーに示します。バッファーが満杯になった場合、または特定の時間が経過したときに送信されます。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(TimeSpan、TimeSpan、IScheduler)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T>(TimeSpan、Int32、IScheduler)	オーバーロード。監視可能なシーケンスの各要素をバッファーに示します。バッファーが満杯になった場合、または特定の時間が経過したときに送信されます。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	バッファー<T、TBufferClosing>(Func<IObservable<TBufferClosing>>)	オーバーロード。観測可能なシーケンスの各要素を連続する重複しないバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	Buffer<T、TBufferOpening、TBufferClosing>(IObservable<TBufferOpening>、Func<TBufferOpening、IObservable<TBufferClosing>>)	オーバーロード。クエリ可能な監視可能シーケンスの各要素を連続する重複しないバッファーに示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<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< を使用して、監視可能なシーケンスに指定した要素が含まれているかどうかを判断します。T>。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	カウント<T>	監視可能なシーケンス内の要素の合計数を表す Int32 を返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	DefaultIfEmpty<T>()	オーバーロード。シーケンスが空の場合は、指定したシーケンスの要素、またはシングルトンシーケンス内の型パラメーターの既定値を返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	DefaultIfEmptyT(T) をする	オーバーロード。シーケンスが空の場合は、指定したシーケンスの要素、またはシングルトンシーケンス内の型パラメーターの既定値を返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	遅延<T>(TimeSpan)	オーバーロード。指定したソースと dueTime の期限別に監視可能なシーケンスを示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	Delay<T>(DateTimeOffset)	オーバーロード。指定したソースと dueTime の期限別に監視可能なシーケンスを示します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	遅延<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	最後に T> を<する	ソース監視可能シーケンスが正常に終了した後、または例外によって終了した後に、指定されたアクションを呼び出します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	First<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	Max<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	マルチキャスト<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>() を繰り返す	オーバーロード。監視可能なシーケンスを無期限に繰り返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>(Int32) を繰り返します	オーバーロード。監視可能なシーケンスを無期限に繰り返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	再生<T>()	オーバーロード。すべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<T>(TimeSpan)	オーバーロード。ウィンドウ内のすべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<T>(Int32)	オーバーロード。 bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<T>(IScheduler)	オーバーロード。すべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	再生<T>(TimeSpan、IScheduler)	オーバーロード。ウィンドウ内のすべての通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<T>(Int32、IScheduler)	オーバーロード。 bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<T>(Int32、TimeSpan)	オーバーロード。ウィンドウ内の bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<T>(Int32、TimeSpan、IScheduler)	オーバーロード。ウィンドウ内の bufferSize 通知を再生する基になるシーケンスに 1 つのサブスクリプションを共有する、接続可能な監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	リプレイ<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, 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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	Single<T>()	オーバーロード。監視可能なシーケンスの唯一の要素を返し、監視可能なシーケンスに要素が 1 つだけ存在しない場合は例外をスローします。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	Single<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	< >() をサブスクライブする	オーバーロード。指定したソースで監視可能なシーケンスを評価します。 (ObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>のサブスクライブ (アクション<T>)	オーバーロード。監視可能なシーケンスに対して要素ハンドラーをサブスクライブします。 (ObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	サブスクライブ<T>(アクション<T>、アクション<例外>)	オーバーロード。要素ハンドラーと例外ハンドラーを監視可能なシーケンスにサブスクライブします。 (ObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>(Action<T>, Action)	オーバーロード。要素ハンドラーと完了ハンドラーを監視可能なシーケンスにサブスクライブします。 (ObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	サブスクライブ<T>(Action<T>, Action<Exception>, Action)	オーバーロード。要素ハンドラー、例外ハンドラー、および完了ハンドラーを監視可能なシーケンスにサブスクライブします。 (ObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	SubscribeOn<T>(SynchronizationContext)	オーバーロード。指定した同期コンテキストでオブザーバーを非同期的にサブスクライブおよびサブスクライブ解除します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	SubscribeOn<T>(コントロール)	オーバーロード。 (ControlObservableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	SubscribeOn<T>(Dispatcher)	オーバーロード。 (DispatcherObservableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	SubscribeOn<T>(DispatcherScheduler)	オーバーロード。 (DispatcherObservableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	SubscribeOn<T>(IScheduler)	オーバーロード。指定したスケジューラでオブザーバーを非同期的にサブスクライブおよびサブスクライブ解除します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	SubscribeOnDispatcher<T>	(DispatcherObservableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>() を同期する	オーバーロード。監視可能なシーケンスを同期します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>(オブジェクト) を同期する	オーバーロード。監視可能なシーケンスを同期します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	< > を取る	監視可能なシーケンスの先頭から、指定した数の連続した値を返します。 (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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(TimeSpan)	オーバーロード。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException のいずれかを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(DateTimeOffset)	オーバーロード。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException を返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(TimeSpan、IObservable<T>)	オーバーロード。 dueTime が経過した場合は、ソース監視可能シーケンスまたはその他の監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(DateTimeOffset、IObservable<T>)	オーバーロード。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException のいずれかを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(TimeSpan、IScheduler)	オーバーロード。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException のいずれかを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(DateTimeOffset、IScheduler)	オーバーロード。 dueTime が経過した場合は、監視可能なシーケンスまたは TimeoutException のいずれかを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(TimeSpan、IObservable<T>、IScheduler)	オーバーロード。 dueTime が経過した場合は、ソース監視可能シーケンスまたはその他の監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムアウト<T>(DateTimeOffset、IObservable<T>、IScheduler)	オーバーロード。 dueTime が経過した場合は、ソース監視可能シーケンスまたはその他の監視可能なシーケンスを返します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	タイムスタンプ<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によって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ToNotifier<T>	オブザーバーから通知コールバックを作成します。 (オブザーバーによって定義。
パブリック拡張メソッドパブリック拡張メソッド	ToTask<T>()	オーバーロード。監視可能シーケンスの最後の値を含むタスクを返します。 (TaskObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ToTask<T>(オブジェクト)	オーバーロード。監視可能シーケンスの最後の値を含むタスクを返します。 (TaskObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ToTask<T>(CancellationToken)	オーバーロード。監視可能シーケンスの最後の値を含むタスクを返します。 (TaskObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ToTask<T>(CancellationToken, Object)	オーバーロード。監視可能シーケンスの最後の値を含むタスクを返します。 (TaskObservableExtensionsによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>(Func<T, Boolean>)	オーバーロード。述語に基づいて監視可能なシーケンスの要素をフィルター処理します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	<T>(Func<T,Int32, Boolean>)	オーバーロード。要素のインデックスを組み込むことで、述語に基づいて監視可能なシーケンスの要素をフィルター処理します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(Int32)	オーバーロード。観測可能シーケンスの各要素を、要素数情報に基づいて生成される連続する重複しないウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(TimeSpan)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される連続する重複しないウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(Int32、Int32)	オーバーロード。監視可能シーケンスの各要素を、要素数情報に基づいて生成される 0 個以上のウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(TimeSpan、IScheduler)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される連続する重複しないウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(TimeSpan、TimeSpan)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(TimeSpan、Int32)	オーバーロード。監視可能なシーケンスの各要素を、完全または特定の時間が経過したときに完了したウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<T>(TimeSpan、TimeSpan、IScheduler)	オーバーロード。監視可能シーケンスの各要素を、タイミング情報に基づいて生成される 0 個以上のウィンドウに投影します。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	ウィンドウ<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、TResult>)	オーバーロード。 2 つの観測可能なシーケンスを、ペアごとの方法で要素を組み合わせることにより、1 つの観測可能なシーケンスにマージします。 (Observableによって定義されます)。
パブリック拡張メソッドパブリック拡張メソッド	Zip<T、TSecond、TResult>(IEnumerable<TSecond>、Func<T、TSecond、TResult>)	オーバーロード。セレクター関数を使用して、監視可能なシーケンスと列挙可能なシーケンスを 1 つの監視可能なシーケンスにマージします。 (Observableによって定義されます)。

ページのトップへ

備考

サブジェクトはプロキシと同様に動作します。サブスクライバーとパブリッシャーの両方として実行されます。これは、IObserver インターフェイスと IObservable インターフェイスをサポートすることによって実現されます。 IObserver インターフェイスを使用して、複数のストリームまたはデータシーケンスにサブジェクトをサブスクライブできます。その後、データは IObservable インターフェイスを介して、サブスクライブされているすべてのオブザーバーに発行されます。通常の件名では、スケジューラを使用して、サブクリブオブザーバーへの発信呼び出しを同期します。

例

この例では、サブジェクトクラスの使用方法を示します。文字列型の Subject のインスタンスは、2 つのニュースフィードの例をサブスクライブするために使用されます。これらのフィードは、5 秒以下の間隔でランダムなニュースの見出しを公開するだけです。その後、サブジェクトの監視可能なインターフェイスに対して 2 つのサブスクリプションが作成され、結合されたデータストリームが受信されます。 1 つのサブスクリプションでは、データストリームの各項目が "すべてのニュース" として報告されます。他のサブスクリプションでは、ストリーム内の各見出しがフィルター処理され、ローカルの見出しのみがレポートされます。サブスクリプションはどちらも、受け取った各見出しをコンソールウィンドウに書き込みます。ユーザーが Enter キーを押すと処理が終了し、Dispose が呼び出されて両方のサブスクリプションが取り消されます。

using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Reactive.Concurrency;
using System.Threading;

namespace Example
{
  class Program
  {
    static void Main()
    {
      //*****************************************************************************************************//
      //***                                                                                               ***//
      //*** A subject acts similar to a proxy in that it acts as both a subscriber and a publisher        ***//
      //*** It's IObserver interface can be used to subscribe to multiple streams or sequences of data.   ***//
      //*** The data is then published through it's IObservable interface.                                ***//
      //***                                                                                               ***//
      //*** In this example a simple string based subject is used to subscribe to multiple news feeds     ***//
      //*** that provide random news headlines. Subscribers can then subscribe to the subject's           ***//
      //*** observable interface to observe the data stream(s) or a subset ofthe stream(s). Below we      ***//
      //*** subscribe the subject to two different news headline feeds. Then two subscriptions are        ***//
      //*** created: one for delivery of all news headlines, the other receives only local news headlines ***//
      //***                                                                                               ***//
      //*** A local news headline just contains the newsLocation substring ("in your area.").             ***//
      //***                                                                                               ***//
      //*****************************************************************************************************//

      Subject<string> mySubject = new Subject<string>();


      //*********************************************************//
      //*** Create news feed #1 and subscribe mySubject to it ***//
      //*********************************************************//
      NewsHeadlineFeed NewsFeed1 = new NewsHeadlineFeed("Headline News Feed #1");
      NewsFeed1.HeadlineFeed.Subscribe(mySubject);

      //*********************************************************//
      //*** Create news feed #2 and subscribe mySubject to it ***//
      //*********************************************************//
      NewsHeadlineFeed NewsFeed2 = new NewsHeadlineFeed("Headline News Feed #2");
      NewsFeed2.HeadlineFeed.Subscribe(mySubject);


      Console.WriteLine("Subscribing to news headline feeds.\n\nPress ENTER to exit.\n");

      //*****************************************************************************************************//
      //*** Create a subscription to the subject's observable sequence. This subscription will receive    ***//
      //*** all headlines.                                                                                ***//
      //*****************************************************************************************************//
      IDisposable allNewsSubscription = mySubject.Subscribe(x => 
      {
        Console.WriteLine("Subscription : All news subscription\n{0}\n", x);
      });


      //*****************************************************************************************************//
      //*** Create a subscription to the subject's observable sequence. This subscription will filter for ***//
      //*** only local headlines.                                                                         ***//
      //*****************************************************************************************************//

      IDisposable localNewsSubscription = mySubject.Where(x => x.Contains("in your area.")).Subscribe(x => 
      {
        Console.WriteLine("\n************************************\n" +
                          "***[ Local news headline report ]***\n" +
                          "************************************\n{0}\n\n", x);
      });

      Console.ReadLine();


      //*********************************//
      //*** Cancel both subscriptions ***//
      //*********************************//

      allNewsSubscription.Dispose();
      localNewsSubscription.Dispose();
    }
  }



  //*********************************************************************************//
  //*** The NewsHeadlineFeed class is just a mock news feed in the form of an     ***//
  //*** observable sequence in Reactive Extensions.                               ***//
  //*********************************************************************************//
  class NewsHeadlineFeed
  {
    private string feedName;                     // Feedname used to label the stream
    private IObservable<string> headlineFeed;    // The actual data stream
    private readonly Random rand = new Random(); // Used to stream random headlines.


    //*** A list of predefined news events to combine with a simple ___location string ***//
    static readonly string[] newsEvents = { "A tornado occurred ",
                                            "Weather watch for snow storm issued ",
                                            "A robbery occurred ",
                                            "We have a lottery winner ",
                                            "An earthquake occurred ",
                                            "Severe automobile accident "};

    //*** A list of predefined ___location strings to combine with a news event. ***//
    static readonly string[] newsLocations = { "in your area.",
                                               "in Dallas, Texas.",
                                               "somewhere in Iraq.",
                                               "Lincolnton, North Carolina",
                                               "Redmond, Washington"};

    public IObservable<string> HeadlineFeed
    {
      get { return headlineFeed; }
    }

    public NewsHeadlineFeed(string name)
    {
      feedName = name;

      //*****************************************************************************************//
      //*** Using the Generate operator to generate a continous stream of headline that occur ***//
      //*** randomly within 5 seconds.                                                        ***//
      //*****************************************************************************************//
      headlineFeed = Observable.Generate(RandNewsEvent(),
                                         evt => true,
                                         evt => RandNewsEvent(),
                                         evt => { Thread.Sleep(rand.Next(5000)); return evt; },
                                         Scheduler.ThreadPool);
    }


    //****************************************************************//
    //*** Some very simple formatting of the headline event string ***//
    //****************************************************************//
    private string RandNewsEvent()
    {
      return "Feedname     : " + feedName + "\nHeadline     : " + newsEvents[rand.Next(newsEvents.Length)] + 
             newsLocations[rand.Next(newsLocations.Length)];
    }
  }
}

コード例を使用して、次の出力が生成されました。

Subscribing to news headline feeds.

Press ENTER to exit.

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : A robbery occurred somewhere in Iraq.

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : An earthquake occurred in Dallas, Texas.

Subscription : All news subscription
Feedname     : Headline News Feed #1
Headline     : We have a lottery winner in your area.

********************************** [ ローカルニュースの見出しレポート ]********************************** フィード名: ヘッドラインニュースフィード #1 ヘッドライン: 私たちはあなたの地域で宝くじの勝者を持っています。

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : Severe automobile accident Redmond, Washington

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : We have a lottery winner in Dallas, Texas.

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : An earthquake occurred in Dallas, Texas.

Subscription : All news subscription
Feedname     : Headline News Feed #1
Headline     : We have a lottery winner somewhere in Iraq.

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : Severe automobile accident somewhere in Iraq.

Subscription : All news subscription
Feedname     : Headline News Feed #2
Headline     : An earthquake occurred in your area.

********************************** [ 地域ニュースの見出しレポート ]********************************** フィード名 : ヘッドラインニュースフィード #2 ヘッドライン : お住まいの地域で地震が発生しました。

スレッドセーフ

この型のパブリック静的 (Visual Basic で共有) メンバーはスレッドセーフです。インスタンスメンバーがスレッドセーフであるとは限りません。

次の方法で共有

Subject<T> クラス

継承階層

構文

型パラメーター

コンス トラクター

メソッド

拡張メソッド

備考

例

スレッド セーフ

関連項目

参考

その他のリソース

コンストラクター

スレッドセーフ