Stream multiplexing for Go