Admilson Cossa

Resource Safety And Budgeted Work Last time we showed backpressure with channels and work().stream() — pausing the producer the moment the consumer slows down. This article puts hard boundaries on cost and guarantees that cleanup always runs, even when the user hits Ctrl-C, the deadline fires, or a sibling throws. Last time we showed backpressure with channels and we showed backpressure with channels and work().stream() Three primitives. One ownership tree. run.bracket — open, use, release.

Backpressure For Streaming Pipelines Last time we showed how to terminate non-cooperative CPU work at the worker boundary. This article stays cooperative but adds the missing piece: backpressure, the runtime contract that lets a producer pause the moment the consumer can't keep up. A RAG ingest pipeline has a billion candidate documents. You only need the 25 that match a downstream filter.