multistream-select: Include \n in length. (#439)

* multistream-select: Include `\n` in length.

* Add comment to explain the +1.

* Re-enable test.
This commit is contained in:
Toralf Wittner 2018-09-03 11:13:42 +02:00 committed by GitHub
parent ccc5aacafc
commit b5acf226f9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 1 additions and 2 deletions

View File

@ -111,7 +111,7 @@ where
let mut buf = encode::usize_buffer();
let mut out_msg = Vec::from(encode::usize(list.len(), &mut buf));
for elem in &list {
out_msg.extend(encode::usize(elem.len(), &mut buf));
out_msg.extend(encode::usize(elem.len() + 1, &mut buf)); // +1 for '\n'
out_msg.extend_from_slice(elem);
out_msg.extend(iter::once(b'\n'));
}

View File

@ -142,7 +142,6 @@ fn no_protocol_found() {
}
#[test]
#[ignore] // TODO: not working
fn select_proto_parallel() {
let listener = TcpListener::bind(&"127.0.0.1:0".parse().unwrap()).unwrap();
let listener_addr = listener.local_addr().unwrap();