WIP

Cargo.toml

@@ -19,9 +19,9 @@ stream = ["bytes"]
 
 [dependencies]
 log = "0.4"
-futures-preview = { version = "0.3.0-alpha.18", features = ["async-await", "nightly"] }
-pin-project = "0.4.0-alpha.9"
-tokio-io = "0.2.0-alpha.5"
+futures-preview = { version = "0.3.0-alpha.19", features = ["async-await"] }
+pin-project = "0.4.0"
+tokio-io = "0.2.0-alpha.6"
 
 [dependencies.tungstenite]
 #version = "0.9.1"
@@ -44,13 +44,13 @@ git = "https://github.com/sbstp/tokio-dns.git"
 
 [dependencies.tokio-net]
 optional = true
-version = "0.2.0-alpha.5"
+version = "0.2.0-alpha.6"
 
 [dependencies.tokio-tls]
 optional = true
-version = "0.3.0-alpha.5"
+version = "0.3.0-alpha.6"
 
 [dev-dependencies]
-tokio = "0.2.0-alpha.5"
+tokio = "0.2.0-alpha.6"
 url = "2.0.0"
-env_logger = "0.6.1"
+env_logger = "0.7.0"

src/handshake.rs

@@ -159,7 +159,7 @@ where
 {
     type Output = Result<Role::FinalResult, Error<Role>>;
 
-    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
+    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         let this = self.project();
         let mut s = this.0.take().expect("future polled after completion");
 

src/lib.rs

@@ -304,7 +304,7 @@ where
 {
     type Output = Result<(), WsError>;
 
-    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
+    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         let this = self.project();
         let message = this.message.take().expect("Cannot poll twice");
         Poll::Ready(this.stream.with_context(cx, |s| s.write_message(message)))
@@ -324,7 +324,7 @@ where
 {
     type Output = Result<(), WsError>;
 
-    fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
+    fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         let this = self.project();
         let message = this.message.take().expect("Cannot poll twice");
         Poll::Ready(this.stream.with_context(cx, |s| s.close(message)))