2015-01-19 3 views
0

내가 반응성 확장의 코드를 읽은 후, 나는 방법 SubscribeSafe(sink) 클래스 ObservableExtensions에서 것을 알게이 코드Rx의 IObservable과 ObservableExtensions의 관계는 무엇입니까?

private readonly IObservable<TSource> _source; 
protected override IDisposable Run(IObserver<TResult> observer, IDisposable cancel, Action<IDisposable> setSink) 
{ 
    var sink = new _(this, observer, cancel); 
    setSink(sink); 
    return _source.SubscribeSafe(sink); 
} 

을 발견하고, 클래스는 인터페이스 IObservable를 구현하지 않습니다. 매개 변수 _source의 멤버 함수가 SubscribeSafe() 인 이유는 무엇입니까?

답변

2

ObservableExtensions의 메소드가 확장 메소드이기 때문입니다. 그들에 대해 읽을 수 있습니다 here.

+0

감사합니다. 그것은 정확히 내가 알고 싶은 것입니다. :) – Tyoshi