remove unsafe

src/ws/frame.rs

@@ -260,15 +260,14 @@ impl Frame {
         }
 
         // unmask
-        if let Some(mask) = mask {
+        let data = if let Some(mask) = mask {
-            // Unsafe: request body stream is owned by WsStream. only one ref to
+            let mut buf = BytesMut::new();
-            // bytes exists. Bytes object get freezed in continuous non-overlapping blocks
+            buf.extend_from_slice(&data);
-            let p: &mut [u8] = unsafe {
+            apply_mask(&mut buf, mask);
-                let ptr: &[u8] = &data;
+            buf.freeze()
-                &mut *(ptr as *const _ as *mut _)
+        } else {
-            };
+            data
-            apply_mask(p, mask);
+        };
-        }
 
         Ok(Async::Ready(Some(Frame {
             finished,