Set correct masks on server and client

Fixes #104 regression

Author: illegalprime

src/client/builder.rs

@@ -545,7 +545,7 @@ impl<'u> ClientBuilder<'u> {
 			return Err(WebSocketError::ResponseError("Connection field must be 'Upgrade'"));
 		}
 
-		Ok(Client::unchecked(reader, response.headers))
+		Ok(Client::unchecked(reader, response.headers, true, false))
 	}
 }
 

src/client/mod.rs

@@ -120,14 +120,19 @@ impl<S> Client<S>
 	/// a stream that has a websocket connection already set up.
 	/// If in doubt, don't use this!
 	#[doc(hidden)]
-	pub fn unchecked(stream: BufReader<S>, headers: Headers) -> Self {
+	pub fn unchecked(
+		stream: BufReader<S>,
+		headers: Headers,
+		out_mask: bool,
+		in_mask: bool,
+	) -> Self {
 		Client {
 			headers: headers,
 			stream: stream,
 			// NOTE: these are always true & false, see
 			// https://tools.ietf.org/html/rfc6455#section-5
-			sender: Sender::new(true),
-			receiver: Receiver::new(false),
+			sender: Sender::new(out_mask),
+			receiver: Receiver::new(in_mask),
 		}
 	}
 

src/server/upgrade/mod.rs

@@ -128,7 +128,7 @@ impl<S> WsUpgrade<S>
 			None => BufReader::new(self.stream),
 		};
 
-		Ok(Client::unchecked(stream, self.headers))
+		Ok(Client::unchecked(stream, self.headers, false, true))
 	}
 
 	/// Reject the client's request to make a websocket connection.