Cancellable, backpressure-aware Transform streams (pattern and trade-offs)

Use Node’s stream contract to build a Transform that processes async-iterator input, pauses when write() applies backpressure, and cancels with an observable error instead of leaving buffered work behind.