actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-11-24 07:53:00 +01:00
Code Issues Releases Wiki Activity

explicit impl traits for ws connect

Browse Source
This commit is contained in:
Nikolay Kim 2019-03-29 14:26:11 -07:00
parent 744d82431d
commit aebeb511cd
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
awc/src/ws.rs
View File

@ -3,7 +3,7 @@ use std::io::Write;
use std::rc::Rc; use std::rc::Rc;
use std::{fmt, str}; use std::{fmt, str};
use actix_codec::Framed; use actix_codec::{AsyncRead, AsyncWrite, Framed};
use actix_http::{ws, Payload, RequestHead}; use actix_http::{ws, Payload, RequestHead};
use bytes::{BufMut, BytesMut}; use bytes::{BufMut, BytesMut};
#[cfg(feature = "cookies")] #[cfg(feature = "cookies")]
@ -13,7 +13,6 @@ use tokio_timer::Timeout;
pub use actix_http::ws::{CloseCode, CloseReason, Frame, Message}; pub use actix_http::ws::{CloseCode, CloseReason, Frame, Message};
use crate::connect::BoxedSocket;
use crate::error::{InvalidUrl, SendRequestError, WsClientError}; use crate::error::{InvalidUrl, SendRequestError, WsClientError};
use crate::http::header::{ use crate::http::header::{
self, HeaderName, HeaderValue, IntoHeaderValue, AUTHORIZATION, self, HeaderName, HeaderValue, IntoHeaderValue, AUTHORIZATION,
@ -214,7 +213,10 @@ impl WebsocketsRequest {
pub fn connect( pub fn connect(
mut self, mut self,
) -> impl Future< ) -> impl Future<
Item = (ClientResponse, Framed<BoxedSocket, ws::Codec>), Item = (
ClientResponse,
Framed<impl AsyncRead + AsyncWrite, ws::Codec>,
),
Error = WsClientError, Error = WsClientError,
> { > {
if let Some(e) = self.err.take() { if let Some(e) = self.err.take() {