Операторы обратной зависимости

стратегии для работы с Observable, которые производят элементы быстрее, чем их наблюдатели их потребляют

В ReactiveX легко попасть в ситуацию, когда Observable испускает элементы быстрее, чем оператор или наблюдатель их могут потреблять. Это создаёт проблему, как обрабатывать такой растущий запрос необработанных элементов.

Например, представьте, что вы используете оператор Zip, чтобы объединить два бесконечных Observable, один из которых испускает элементы в два раза чаще, чем другой. Примитивное реализация оператора должна поддерживать постоянно расширяющийся буфер элементов, испускаемых более быстрым Observable, чтобы в конечном итоге объединить их с элементами, испускаемыми более медленным. Это может привести к тому, что ReactiveX займёт значительное количество системных ресурсов.

Существует множество стратегий, с помощью которых вы можете осуществлять управление потоком и обратную зависимость в ReactiveX, чтобы устранить проблемы, возникающие, когда быстро производящий Observable сталкивается с медленно потребляющим наблюдателем. К ним относятся, в некоторых реализациях ReactiveX, реактивная обратная зависимость с подтягиванием и некоторые операторы, специализирующиеся на обратной зависимости.

Observable холодный испускает определённую последовательность элементов, но может начать испускать эту последовательность, когда его наблюдатель сочтёт это удобным, и с любой желаемой скоростью, не нарушая целостности последовательности. Например, если вы преобразуете статичный итерируемый объект в Observable, этот Observable будет испускать ту же последовательность элементов независимо от того, когда к нему подписываются или с какой частотой эти элементы наблюдаются. Примеры элементов, испускаемых холодным Observable, могут включать результаты запроса к базе данных, извлечения файлов или запроса к веб-серверу.

Observable горячий начинает генерировать элементы для испускания сразу же после создания. Подписчики обычно начинают наблюдать за последовательностью элементов, испускаемых горячим Observable, где-то посередине последовательности, начиная с первого элемента, испускаемого Observable после создания подписки. Такой Observable испускает элементы со своей скоростью, и от наблюдателей зависит, смогут ли они следить за этим. Примеры элементов, испускаемых горячим Observable, могут включать события мыши и клавиатуры, системные события или цены акций.

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

Холодные Observable идеально подходят для модели реактивной обратной зависимости с подтягиванием, реализованной в некоторых реализациях ReactiveX (которое описано в другом месте). Горячие Observable обычно плохо справляются с моделью реактивной обратной зависимости с подтягиванием и являются лучшими кандидатами для других стратегий управления потоком, таких как использование операторов, описанных на этой странице, или операторов, таких как Buffer, Sample, Debounce или Window.

См. также

• Buffer
• Sample
• Debounce
• Window

Информация о языке

RxGroovy onBackpressureBuffer onBackpressureDrop onBackpressureLatest

RxGroovy реализует реактивную обратную связь pull, и многие его операторы поддерживают эту форму обратной связи. Также есть три оператора, которые можно применить к Observable, не написанным с поддержкой обратной связи:

RxJava 1․x onBackpressureBuffer onBackpressureDrop onBackpressureLatest

RxJava реализует реактивную обратную связь pull, и многие его операторы поддерживают эту форму обратной связи. Также есть три оператора, которые можно применить к Observable, не написанным с поддержкой обратной связи:

RxJS controlled pausable pausableBuffered stopAndWait windowed

RxJS реализует обратную связь, преобразуя обычное Observable в ControlledObservable с помощью оператора controlled. Это заставляет Observable учитывать запросы от его наблюдателей, а не отправлять элементы по собственной инициативе.

Также есть два оператора, которые преобразуют обычное Observable в паузную форму.