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

Фактически это связано с реализацией отдельных операторов, но встроенные будут буферизироваться на основе для каждой подписки, поэтому медленный потребитель не будет блокировать других подписчиков, если, конечно, подписчики не делятся потоки.

Кстати, Rx не всегда защищает грамматику Rx; например, вы несете ответственность за то, чтобы не выполнять одновременных вызовов OnNext по теме. Вы можете использовать Observable.Synchronize(), чтобы исправить это.

Явление, о котором вы говорите, называется обратным давлением, и команда Rx в настоящее время изучает различные способы справиться с этой ситуацией. Одним из решений может быть обратная связь с Observable, чтобы он «замедлился».

Чтобы уменьшить обратное давление, вы можете использовать операторы с потерями, такие как Throttle или Sample.

Ответ Тимоти в основном правильный, но возможно, что обратное давление возникнет в одном потоке. Это может произойти, если вы используете асинхронный код. В этом смысле противодействие связано с синхронизацией и планированием, а не с потоками (напомним, что по умолчанию Rx является однопоточным).

Если вы столкнетесь со сценарием, когда события создаются быстрее, чем они могут быть использованы, и вы не используете оператор с потерями для уменьшения обратного давления, эти элементы обычно планируются / помещаются в очередь / буферизируются, что может привести к много выделения памяти.

Лично для меня это не было проблемой, поскольку обычно события обрабатываются быстрее, чем передаются, или потеря событий просто не возможна, и поэтому дополнительное потребление памяти неизбежно.

Если подписчик обрабатывает в том же потоке, что и излучающий наблюдаемый объект, данные не могут поступать быстрее, чем подписчик может потреблять.

IObservable<int> data = ...;
var subscription = data.Subscribe(n => Console.WriteLine(n));

В этом примере каждый int, исходящий из data, будет записан в консоль до того, как будет отправлен следующий int.

Если подписка пересекает потоки, то вышеперечисленное не выполняется.