Reads the next token from the stream
Future<String> readNextToken(P2PStream<dynamic> stream) async { final bytes = await readDelimited(stream); return utf8.decode(bytes); }