Nickiel/church_controller_rust
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

an ilfated test at best. can you really connect to the same port twice?

Browse source
This commit is contained in:
Nickiel12 2021-12-29 22:36:13 -08:00
parent 6a2d56b0bc
commit 9b13f6a6ce
1 changed files with 0 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
src/tests/socket_handler_tests.rs
View file

@ -74,31 +74,3 @@ fn can_handle_delayed_messages() {
socket.close(); socket.close();
} }
#[test]
fn can_send_and_receive_on_stream() {
let listener = Socket::make_listener("localhost:5006");
let (tx_1, rx_1) = unbounded::<String>();
let mut socket = Socket::handle_connections(listener, tx_1);
let mut outgoing = std::net::TcpStream::connect("localhost:5006").unwrap();
outgoing.set_read_timeout(Some(Duration::from_millis(1000))).expect("couln't set timout");
outgoing.write("such a test!\n".as_bytes()).unwrap();
outgoing.flush().unwrap();
thread::sleep(Duration::from_millis(250));
assert_eq!(rx_1.try_recv().unwrap(), "such a test!\n");
socket.send("this is another test!".to_string());
thread::sleep(Duration::from_millis(250));
let mut buffer = [0; 256];
let msg_len = outgoing.read(&mut buffer).unwrap();
assert!(msg_len != 0);
let message = String::from_utf8_lossy(&buffer[0..msg_len]);
assert_eq!("this is another test!", message.into_owned());
drop(outgoing);
socket.close();
}