Ich habe eine heiße beobachtbare, die ich normalerweise mit einer normalen implementiereSubject darunter, so dass interessenten einen live stream von benachrichtigungen abonnieren können.

Jetzt möchte ich diesen Live-Stream beibehalten, aber auch einen historischen Stream aller Ereignisse anzeigen, die UND mit absoluten Zeiten versehen sind, um zu wissen, wann genau sie aufgetreten sind, UND den Abonnenten zu ermöglichen, den historischen Stream auf einen beliebigen zu verschieben Zeitpunkt, bevor die Chronologie wiedergegeben wird.

Ich glaube, dass das meiste davon mit einer erreicht werden könnteHistoricalScheduler und seine AdvanceTo-Methode, aber ich bin nicht sicher, wie genau?Und ist Gebrauch vonZeitstempel die Zeiten der Ereignisse benötigt zu retten?Und ist einReplaySubject Müssen Sie den Live-Stream in historischen Datensätzen zwischenspeichern, die dann mit dem HistoricalScheduler wiedergegeben werden können?

Wie genau können diese beiden Streams für dieselbe Quelle implementiert werden, oder mit anderen Worten, wie kann das Folgende an die aktuellen Anforderungen angepasst werden?

[ sehen"Die Vergangenheit wiederholen" Überschrift]