Предварительный исторический поток и прямой эфир в Rx

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

Теперь я хотел бы сохранить этот живой поток, но также предоставить исторический поток всех событий, которые были и были привязаны к этим уведомлениям в абсолютное время, чтобы знать, когда именно они произошли, КАК ХОРОШО, КАК позволяют подписчикам передавать исторический поток любому момент времени до воспроизведения хронологии.

Я считаю, что большая часть этого может быть достигнута сHistoricalScheduler и его метод AdvanceTo, но ям точно не знаю как?И это использованиедатируемые чтобы сохранить время необходимых событий?И являетсяReplaySubject нужно кешировать прямой поток в исторические записи, которые затем можно воспроизвести с помощью HistoricalScheduler?

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

[ увидеть "Переигрывая прошлое " заголовок]

Ответы на вопрос(1)

Ваш ответ на вопрос