The SuspendableConsumer class provides PushMessage and SetProcessingDelayMillis , but there is no way to…
The SuspendableConsumer class provides PushMessage and SetProcessingDelayMillis , but there is no way to…: a task in LegoFlow-SWE (Harbor dataset). Steps to reproduce: 1. Create a SuspendableConsumer instance. 2. Call SetProcessingDelayMillis to simulate processing time. 3. Push several messages…
The task
**Steps to reproduce:** 1. Create a `SuspendableConsumer` instance. 2. Call `SetProcessingDelayMillis` to simulate processing time. 3. Push several messages via `PushMessage`. 4. Wait for all messages to be consumed. 5. Observe that no callback fires after the last message is fully handled.
Part of Lego-X/LegoFlow-SWE.