ws_stream 0.0.0

Provide AsyncRead/AsyncWrite over WebSockets (both tokio and 0.3)
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
33
34
35
36
37
38
39
40
41

use
{
	crate :: { import::*, WsStream, WsErr, WsErrKind } ,
};


/// Future representing a finished WS handshake.Accept
//
pub struct Accept<T: AsyncRead01 + AsyncWrite01 >
{
	inner: AndThen< FutureResult<T, tungstenite::error::Error>, AcceptAsync<T, NoCallback>, fn(T) -> AcceptAsync<T, NoCallback> >,
}


impl<T: AsyncRead01 + AsyncWrite01 > Accept<T>
{
	/// Create a new accept handshake from an AsyncRead01/Write
	//
	pub fn new( stream: T ) -> Self
	{
		Self{ inner: ok( stream ).and_then( accept_async ) }
	}
}



impl<T: AsyncRead01 + AsyncWrite01 > Future01 for Accept<T>
{
	type Item  = WsStream<T>;
	type Error = WsErr   ;

	fn poll( &mut self ) -> Result< Async< Self::Item >, Self::Error >
	{
		match self.inner.poll()
		{
			Ok ( Async::Ready   ( ws ) ) => { trace!( "accept ok"      ); Ok ( Async::Ready( WsStream::new(ws) ) ) },
			Ok ( Async::NotReady       ) => { trace!( "accept pending" ); Ok ( Async::NotReady                   ) },
			Err( e                     ) => { error!( "{}", &e         ); Err( WsErrKind::WsHandshake.into()     ) },
		}
	}
}