AsyncSubject<T> 클래스

비동기 작업의 결과를 나타냅니다.

상속 계층 구조

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

네임스페이스:System.Reactive.Subjects
어셈블리: System.Reactive(System.Reactive.dll)

통사론

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

'Usage
Dim instance As AsyncSubject(Of T)

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

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

[<SealedAttribute>]
type AsyncSubject<'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
  형식입니다.

AsyncSubject<T> 형식은 다음 멤버를 노출합니다.

생성자

맨 위로

방법

맨 위로

확장 메서드

맨 위로

발언

AsyncSubject는 관찰자 인터페이스가 완료를 받으면 해당 관찰자 인터페이스에서 받은 최종 항목을 게시합니다. 또한 AsyncSubject는 이후 구독의 최종 항목을 관찰 가능한 인터페이스에 캐시합니다. 따라서 해당 AsyncSubject에 대한 새 구독에도 해당 구독에 게시되는 최종 항목이 있습니다.

예제

이 예제에서는 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...

스레드 안전성

이 형식의 모든 공용 정적(Visual Basic에서 공유) 멤버는 스레드로부터 안전합니다. 모든 인스턴스 멤버는 스레드로부터 안전하게 보호되지 않습니다.

참고 항목

참조

system.Reactive.Subjects 네임스페이스