IObservable<T>.Subscribe(IObserver<T>) IObservable<T>.Subscribe(IObserver<T>) IObservable<T>.Subscribe(IObserver<T>) IObservable<T>.Subscribe(IObserver<T>) Method


オブザーバーが通知を受け取ることをプロバイダーに通知します。 Notifies the provider that an observer is to receive notifications.

 IDisposable ^ Subscribe(IObserver<T> ^ observer);
public IDisposable Subscribe (IObserver<out T> observer);
abstract member Subscribe : IObserver<'T> -> IDisposable
Public Function Subscribe (observer As IObserver(Of Out T)) As IDisposable


IObserver<T> IObserver<T> IObserver<T> IObserver<T>

通知を受け取るオブジェクト。 The object that is to receive notifications.


プロバイダーが通知の送信を完了する前に、オブザーバーが通知の受信を停止できるインターフェイスへの参照。 A reference to an interface that allows observers to stop receiving notifications before the provider has finished sending them.


次の例を示しています、Subscribe緯度と経度の情報を報告するアプリケーションのメソッド。The following example illustrates the Subscribe method for an application that reports latitude and longitude information. 定義、IList<T>すべてオブザーバーへの参照を格納するコレクション オブジェクト。It defines an IList<T> collection object that stores references to all observers. という名前のプライベート クラスも返しますUnsubscriberを実装する、IDisposableインターフェイスし、により、サブスクライバーにイベント通知の受信を停止します。It also returns a private class named Unsubscriber that implements the IDisposable interface and enables subscribers to stop receiving event notifications. 例を参照してください、IObservable<T>完全な例についてはトピック。See the Example section of the IObservable<T> topic for the complete example.

private List<IObserver<Location>> observers;

public IDisposable Subscribe(IObserver<Location> observer) 
   if (! observers.Contains(observer)) 
   return new Unsubscriber(observers, observer);

private class Unsubscriber : IDisposable
   private List<IObserver<Location>>_observers;
   private IObserver<Location> _observer;

   public Unsubscriber(List<IObserver<Location>> observers, IObserver<Location> observer)
      this._observers = observers;
      this._observer = observer;

   public void Dispose()
      if (_observer != null && _observers.Contains(_observer))
Private observers As List(Of IObserver(Of Location))

Public Function Subscribe(ByVal observer As System.IObserver(Of Location)) As System.IDisposable _
                         Implements System.IObservable(Of Location).Subscribe
   If Not observers.Contains(observer) Then
   End If
   Return New Unsubscriber(observers, observer)
End Function

Private Class Unsubscriber : Implements IDisposable
   Private _observers As List(Of IObserver(Of Location))
   Private _observer As IObserver(Of Location)

   Public Sub New(ByVal observers As List(Of IObserver(Of Location)), ByVal observer As IObserver(Of Location))
      Me._observers = observers
      Me._observer = observer
   End Sub

   Public Sub Dispose() Implements IDisposable.Dispose
      If _observer IsNot Nothing AndAlso _observers.Contains(_observer) Then
      End If
   End Sub
End Class


Subscribeプッシュ ベースの通知のオブザーバーを登録するメソッドを呼び出す必要があります。The Subscribe method must be called to register an observer for push-based notifications. 一般的な実装、Subscribeメソッドは、次を実行します。A typical implementation of the Subscribe method does the following:

  • など、コレクション オブジェクトで、オブザーバーへの参照を格納、List<T>オブジェクト。It stores a reference to the observer in a collection object, such as a List<T> object.

  • 参照を返します、IDisposableインターフェイス。It returns a reference to an IDisposable interface. これにより、登録を解除するオブザーバー (つまり、通知の受信を停止する)、プロバイダーが送信を完了という、サブスクライバーの前にOnCompletedメソッド。This enables observers to unsubscribe (that is, to stop receiving notifications) before the provider has finished sending them and called the subscriber's OnCompleted method.

時間の特定のインスタンスに特定、IObservable<T>実装はすべてのサブスクリプションを処理し、すべてのサブスクライバーに通知する責任を負います。At any given time, a particular instance of an IObservable<T> implementation is responsible for handling all subscriptions and notifying all subscribers. しない限り、特定のドキュメントIObservable<T>実装がそれを示すオブザーバーことは避けてください前提条件について、IObservable<T>など複数のオブザーバーを受信する通知の順番の実装。Unless the documentation for a particular IObservable<T> implementation indicates otherwise, observers should make no assumptions about the IObservable<T> implementation, such as the order of notifications that multiple observers will receive.

Applies to

See Also