AsyncSubject < T > .Dispose 方法

取消訂閱所有觀察者及釋放資源。

Namespace：System.Reactive.Subjects
裝配： System.Reactive.dll) 中的 System.Reactive (

Syntax

'Declaration
Public Sub Dispose

'Usage
Dim instance As AsyncSubject

instance.Dispose()

public void Dispose()

public:
virtual void Dispose() sealed

abstract Dispose : unit -> unit 
override Dispose : unit -> unit 

public final function Dispose()

實作

IDisposable.Dispose ()

範例

在此範例中，AsyncSubject 是用來訂閱以 Range 運算子產生的整數序列。 AsyncSubject 只會在訂閱其完成的序列時傳回值。 序列完成後，AsyncSubject 將會發佈序列中的最終專案。 AsyncSubject 會快取最終專案。 針對該 AsyncSubject 的任何新訂用帳戶，也會將最終專案發佈至該訂用帳戶。

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 an AsyncSubject is used to subscribe to an integer sequence from the Range      ***//
      //*** operator. An AsyncSubject only returns a value when the sequence it is subscribed to completes. ***//
      //*** Once the sequence has completed, the AsyncSubject will publish the final item in the sequence.  ***//
      //*** The AsyncSubject caches the final item. Any new subscriptions against that AsyncSubject will    ***//
      //*** also have the final item published to that subscription as well.                                ***//
      //*******************************************************************************************************//

      var intSequence = Observable.Range(0, 10, Scheduler.ThreadPool);

      AsyncSubject<int> myAsyncSubject = new AsyncSubject<int>();
      intSequence.Subscribe(myAsyncSubject);

      Thread.Sleep(1000);
      myAsyncSubject.Subscribe(i => Console.WriteLine("Final integer for subscription #1 is {0}\n", i),
                               () => Console.WriteLine("subscription #1 completed.\n"));
                                
      
      Console.WriteLine("Sleeping for 5 seconds before subscription2\n");
      Thread.Sleep(5000);

      myAsyncSubject.Subscribe(i => Console.WriteLine("Final integer for subscription #2 after 5 seconds is {0}\n", i),
                               () => Console.WriteLine("subscription #2 completed.\n"));


      Console.WriteLine("Press ENTER to exit...");
      Console.ReadLine();

      myAsyncSubject.Dispose();
    }
  }
}

下列輸出是由範例程式碼所產生。

Final integer for subscription #1 is 9

subscription #1 completed.

Sleeping for 5 seconds before subscription2

Final integer for subscription #2 after 5 seconds is 9

subscription #2 completed.

Press ENTER to exit...

另請參閱

參考

AsyncSubject < T > 類別

System.Reactive.Subjects 命名空間