Bound item delivery and define cancellation, failure, and cleanup behavior for event streams.
Scope
Add a demand-driven single-consumer producer with one-item and max_queue_bytes bounds. Handle consumer cancellation, downstream exceptions, consumer-process death, parser errors, and temporary resource cleanup.
Acceptance Criteria
Pending events never exceed the configured byte budget.
Parser work stops promptly when demand is absent or the consumer cancels.
Parser errors are delivered once and terminate the stream.
Downstream failures and owner death release resources.
Read-ahead and cancellation behavior are covered by tests.
## Objective
Bound item delivery and define cancellation, failure, and cleanup behavior for event streams.
## Scope
Add a demand-driven single-consumer producer with one-item and `max_queue_bytes` bounds. Handle consumer cancellation, downstream exceptions, consumer-process death, parser errors, and temporary resource cleanup.
## Acceptance Criteria
- Pending events never exceed the configured byte budget.
- Parser work stops promptly when demand is absent or the consumer cancels.
- Parser errors are delivered once and terminate the stream.
- Downstream failures and owner death release resources.
- Read-ahead and cancellation behavior are covered by tests.
mmacia
self-assigned this 2026-10-16 10:12:47 +00:00
Blocking a user prevents them from interacting with repositories, such as opening or commenting on pull requests or issues. Learn more about blocking a user.
Objective
Bound item delivery and define cancellation, failure, and cleanup behavior for event streams.
Scope
Add a demand-driven single-consumer producer with one-item and
max_queue_bytesbounds. Handle consumer cancellation, downstream exceptions, consumer-process death, parser errors, and temporary resource cleanup.Acceptance Criteria