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
() 인 이유는 무엇입니까?
감사합니다. 그것은 정확히 내가 알고 싶은 것입니다. :) – Tyoshi