Как я могу узнать, что делает мой запрос на активные запросы?

Я пишу сложный запрос Reactive Extensions с большим количеством операторов. Как я могу посмотреть, что происходит?

Я спрашиваю и отвечаю на это, поскольку он подходит к честной битке и, вероятно, имеет общее общее применение.

Вы можете добавить эту функцию к вашим операторам Rx, пока вы их разрабатываете, чтобы увидеть, что происходит:

public static IObservable Spy(this IObservable source, string opName = null) { opName = opName ?? "IObservable"; Console.WriteLine("{0}: Observable obtained on Thread: {1}", opName, Thread.CurrentThread.ManagedThreadId); return Observable.Create(obs => { Console.WriteLine("{0}: Subscribed to on Thread: {1}", opName, Thread.CurrentThread.ManagedThreadId); try { var subscription = source .Do(x => Console.WriteLine("{0}: OnNext({1}) on Thread: {2}", opName, x, Thread.CurrentThread.ManagedThreadId), ex => Console.WriteLine("{0}: OnError({1}) on Thread: {2}", opName, ex, Thread.CurrentThread.ManagedThreadId), () => Console.WriteLine("{0}: OnCompleted() on Thread: {1}", opName, Thread.CurrentThread.ManagedThreadId) ) .Subscribe(obs); return new CompositeDisposable( subscription, Disposable.Create(() => Console.WriteLine( "{0}: Cleaned up on Thread: {1}", opName, Thread.CurrentThread.ManagedThreadId))); } finally { Console.WriteLine("{0}: Subscription completed.", opName); } }); } 

Вот пример использования, показывает тонкую разницу в поведении Range :

 Observable.Range(0, 1).Spy("Range").Subscribe(); 

Выдает вывод:

 Range: Observable obtained on Thread: 7 Range: Subscribed to on Thread: 7 Range: Subscription completed. Range: OnNext(0) on Thread: 7 Range: OnCompleted() on Thread: 7 Range: Cleaned up on Thread: 7 

Но это:

 Observable.Range(0, 1, Scheduler.Immediate).Spy("Range").Subscribe(); 

Выдает вывод:

 Range: Observable obtained on Thread: 7 Range: Subscribed to on Thread: 7 Range: OnNext(0) on Thread: 7 Range: OnCompleted() on Thread: 7 Range: Subscription completed. Range: Cleaned up on Thread: 7 

Найди отличие?

Очевидно, вы можете изменить это, чтобы записывать в журналы или в Debug, или использовать директивы препроцессора, чтобы сделать постную сквозную подписку на сборку Release и т. Д. …

Вы можете применять Spy всей цепочке операторов. например:

 Observable.Range(0,3).Spy("Range") .Scan((acc, i) => acc + i).Spy("Scan").Subscribe(); 

Выдает вывод:

 Range: Observable obtained on Thread: 7 Scan: Observable obtained on Thread: 7 Scan: Subscribed to on Thread: 7 Range: Subscribed to on Thread: 7 Range: Subscription completed. Scan: Subscription completed. Range: OnNext(1) on Thread: 7 Scan: OnNext(1) on Thread: 7 Range: OnNext(2) on Thread: 7 Scan: OnNext(3) on Thread: 7 Range: OnCompleted() on Thread: 7 Scan: OnCompleted() on Thread: 7 Range: Cleaned up on Thread: 7 Scan: Cleaned up on Thread: 7 

Я уверен, что вы можете найти способы обогащения этого в соответствии с вашими целями.

  • Автоматическое добавление журналов входа / выхода в проект
  • Как можно захватить трассировку стека в C?
  • Отладка в Maven?
  • Отладчик Visual Studio - отображение целочисленных значений в шестнадцатеричном виде
  • Как вы отлаживаете React Native?
  • Как отлаживать проблемы с Ansible?
  • Возможно ли «декомпилировать» Windows .exe? Или, по крайней мере, рассмотреть Ассамблею?
  • Запуск приложения в GDB до тех пор, пока не произойдет исключение
  • Visual Studio отлаживает инструмент «быстрого просмотра» и lambda-выражения
  • Как отладить приложение Spring Boot с Eclipse?
  • Отладить собственный код в Android-библиотеке
  • Давайте будем гением компьютера.