ws_stream_tungstenite 0.1.0

Provide AsyncRead/AsyncWrite over Tungstenite WebSockets
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32


// Tested:
//
// ✔ do not accept a second close frame
//
use crate :: { import::*, tung_websocket::{ closer::Closer } };


#[ test ]
//
fn no_double_close()
{
	// flexi_logger::Logger::with_str( "send_text_backpressure=trace, tungstenite=trace, tokio_tungstenite=trace, ws_stream_tungstenite=trace, tokio=warn" ).start().expect( "flexi_logger");

	let test = async
	{
		let mut closer = Closer::new();

		closer.queue( CloseFrame{ code: CloseCode::Unsupported, reason: "tada"  .into() } ).expect( "queue close" );

		assert!( closer.queue( CloseFrame{ code: CloseCode::Unsupported, reason: "second".into() } ).is_err() );

		trace!( "server: drop websocket" );
	};

	block_on( test );
	info!( "end test" );
}