|
|
@ -254,7 +254,6 @@ impl<S> WebSocketStream<S> { |
|
|
|
impl<T> Stream for WebSocketStream<T> |
|
|
|
impl<T> Stream for WebSocketStream<T> |
|
|
|
where |
|
|
|
where |
|
|
|
T: AsyncRead + AsyncWrite + Unpin, |
|
|
|
T: AsyncRead + AsyncWrite + Unpin, |
|
|
|
AllowStd<T>: Read + Write, |
|
|
|
|
|
|
|
{ |
|
|
|
{ |
|
|
|
type Item = Result<Message, WsError>; |
|
|
|
type Item = Result<Message, WsError>; |
|
|
|
|
|
|
|
|
|
|
@ -278,7 +277,6 @@ where |
|
|
|
impl<T> Sink<Message> for WebSocketStream<T> |
|
|
|
impl<T> Sink<Message> for WebSocketStream<T> |
|
|
|
where |
|
|
|
where |
|
|
|
T: AsyncRead + AsyncWrite + Unpin, |
|
|
|
T: AsyncRead + AsyncWrite + Unpin, |
|
|
|
AllowStd<T>: Read + Write, |
|
|
|
|
|
|
|
{ |
|
|
|
{ |
|
|
|
type Error = WsError; |
|
|
|
type Error = WsError; |
|
|
|
|
|
|
|
|
|
|
|