inputs

Cold, unbuffered message flow for a single collector. Each collection uses the currently open peer. Completion or cancellation closes that peer. Concurrent readers are rejected without interrupting the existing reader. I/O failures propagate to the collector; no reconnection is automatic.