-record(connection, {
    ref :: nerf@gun:stream_reference(),
    pid :: nerf@gun:connection_pid()
}).