Warum löst RX Gas sofort aus, anstatt auf Inaktivität zu warten? ⇐ C#

[Anonymous]

Ich verwende reaktive Erweiterungen (RX.NET), um Inaktivität in einem Strom von Dateiverarbeitungsereignissen zu erkennen und eine Datei nach einer Stillezeit (15 Sekunden) zu schließen. Gasrückgang verhält sich jedoch nicht wie erwartet - es scheint sofort auszulösen, anstatt 15 Sekunden Stille zu warten. < /P>
return _fileProcessedObservable
.Do(_ => Logging.Logger.Info($"[Throttle Test] Triggering SetLive at {DateTime.Now}"))
.Do(SetLive) // Immediately update live status
.Throttle(RTPPacketsWriterConfiguration.StopLiveTimeout) // 15 seconds
.Do(_ => Logging.Logger.Info($"[Throttle Test] Triggering CloseTemporaryAndClearArrays at {DateTime.Now}"))
.SelectMany(_ => Observable.Start(CloseTemporaryAndClearArrays))
.Subscribe();
< /code>
Stoplivetimeout ist 00:00:15 < /p>
Ich habe Ereignisse angemeldet, um das Timing zu verfolgen < /p>
2025-05-16 18:15:45,364 INFO [Throttle Test] Triggering SetLive at 16/05/2025 18:15:45
2025-05-16 18:15:45,366 INFO [Throttle Test] Received file: True at 16/05/2025 18:15:45
2025-05-16 18:15:45,471 INFO [Throttle Test] Triggering SetLive at 16/05/2025 18:15:45
2025-05-16 18:15:45,473 INFO [Throttle Test] Received file: True at 16/05/2025 18:15:45
2025-05-16 18:15:45,577 INFO [Throttle Test] Triggering SetLive at 16/05/2025 18:15:45
2025-05-16 18:15:45,579 INFO [Throttle Test] Received file: True at 16/05/2025 18:15:45
2025-05-16 18:15:45,638 INFO [Throttle Test] Triggering CloseTemporaryAndClearArrays at 16/05/2025 18:15:45
< /code>
Ich erwarte, dass Closetemporary und Cleararrays erst nach 15 Sekunden Inaktivität in _FileProcessedobservable < /p>
ausgelöst werden. _FileProcessedobservable wurde erstellt oder abgeschlossen?>