내가 다음 코드있어했습니다 XXX, YYY는 Schedulers입니다 Observable.Interval(TimeSpan.FromMilliseconds(2500)).SubscribeOn(XXX).ObserveOn(YYY).Subscribe( t => SendCounter(t), e => HandleException(e)); . Inside SendCount
내가 반응성 확장의 코드를 읽은 후, 나는 방법 SubscribeSafe(sink) 클래스 ObservableExtensions에서 것을 알게이 코드 private readonly IObservable<TSource> _source;
protected override IDisposable Run(IObserver<TResult> observer, IDis
내가이 비디오에서 조나단 워싱턴으로 트위터의 예를 다시 시도 세 번째 검색 항목을 입력 중지됩니다. 그러나 얼마 지나지 않아 스트림이 멈 춥니 다. 입력 된 세 번째 검색 주제에서 앱은 더 이상 트윗을 수신하지 않습니다. 그리고 나는 이유를 모른다. 시간에 의존하지 않는 것 같습니다. 왜냐하면 검색 주제를 변경하지 않고 실행하면 계속됩니다. 누구든지 도와