IConnectableObservable<T> 인터페이스

연결 및 연결이 끊어질 수 있는 관찰 가능한 항목을 나타냅니다.

네임스페이스: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> 형식은 다음 멤버를 노출합니다.

방법

맨 위로

확장 메서드

맨 위로

발언

콜드 관찰 가능 항목은 구독 시 실행이 시작됩니다. 즉, 관찰 가능한 시퀀스는 구독이 호출될 때만 관찰자에게 값을 푸시하기 시작합니다. 구독자 간에도 값이 공유되지 않습니다. 이는 구독이 활성화되기 전에도 이미 값을 생성하고 있는 마우스 이동 이벤트 또는 주식 시세와 같은 핫 관찰 가능 항목과 다릅니다. 관찰자가 관찰 가능한 핫 시퀀스를 구독하면 스트림의 현재 값이 표시됩니다. 관찰 가능한 핫 시퀀스는 모든 구독자 간에 공유되며 각 구독자는 시퀀스에서 다음 값을 푸시합니다. 예를 들어 특정 주식 시세를 구독한 사람이 없더라도 시세는 시장 움직임에 따라 계속 해당 값을 업데이트합니다. 구독자가 이 티커에 관심을 등록하면 자동으로 최신 틱이 표시됩니다.

예제

다음 예제에서는 게시 연산자를 사용하여 콜드 관찰 가능한 시퀀스 원본을 핫으로 변환합니다. 이 연산자는 핫이라고 하는 IConnectableObservable<T> 인스턴스를 반환합니다. 게시 연산자는 단일 구독을 여러 구독자에게 브로드캐스트하여 구독을 공유하는 메커니즘을 제공합니다. 핫은 프록시 역할을 하고 원본을 구독한 다음, 원본에서 값을 받으면 해당 값을 자체 구독자로 푸시합니다. 지원 원본에 대한 구독을 설정하고 값을 받기 시작하려면 IConnectableObservable.Connect() 메서드를 사용합니다. IConnectableObservable은 IObservable을 상속하므로 실행을 시작하기 전에 구독을 사용하여 이 핫 시퀀스를 구독할 수 있습니다. 이 예제에서는 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 네임스페이스