Eureka Interest Channel Emits BufferMarker Prematurely When Local Cache Is Empty
Eureka Interest Channel Emits BufferMarker Prematurely When Local Cache Is Empty: a task in LegoFlow-SWE (Harbor dataset). Currently, the channel’s subscriber receives ChangeNotification items via its onNext method. For Add , Modify , and Delete notifications, the channel correctly calls…
The task
Currently, the channel’s subscriber receives `ChangeNotification` items via its `onNext` method. For `Add`, `Modify`, and `Delete` notifications, the channel correctly calls `registry.register(...)` / `registry.unregister(...)`. However, when a `BufferSentinel` with `BufferState.BufferEnd` arrives, no delay is…
Part of Lego-X/LegoFlow-SWE.