gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-09-19 01:36:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

core: test finishing streams

Browse Source
This commit is contained in:
Benjamin Saunders
2018-05-01 19:37:16 -07:00
parent f82774a367
commit d0ee87feba
1 changed files with 20 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/tests.rs
+20
View File
@@ -189,6 +189,26 @@ fn stateless_reset() {
assert_matches!(pair.client.poll(), Some((conn, Event::ConnectionLost { reason: ConnectionError::Reset })) if conn == client_conn);
}
#[test]
fn finish_stream() {
let mut pair = Pair::new(Config { max_remote_uni_streams: 1, ..Config::default()}, Config::default());
let (client_conn, server_conn) = pair.connect();
let s = pair.client.open(client_conn, Directionality::Uni).unwrap();
const MSG: &[u8] = b"hello";
pair.client.write(client_conn, s, MSG).unwrap();
pair.client.finish(client_conn, s);
pair.drive();
assert_matches!(pair.client.poll(), Some((conn, Event::StreamFinished { stream })) if conn == client_conn && stream == s);
assert_matches!(pair.client.poll(), None);
assert_matches!(pair.server.poll(), Some((conn, Event::StreamReadable { stream, fresh: true })) if conn == server_conn && stream == s);
assert_matches!(pair.server.poll(), None);
assert_matches!(pair.server.read_unordered(server_conn, s), Ok((ref data, 0)) if data == MSG);
assert_matches!(pair.server.read_unordered(server_conn, s), Err(ReadError::Finished));
}
#[test]
fn reset_stream() {
let mut pair = Pair::new(Config { max_remote_uni_streams: 1, ..Config::default()}, Config::default());