Add WebSocketStream::split method

examples/client-bytes.rs

@@ -12,8 +12,6 @@
 
 use std::env;
 
-use futures::StreamExt;
-
 use async_std::io;
 use async_std::task;
 use async_tungstenite::async_std::connect_async;

examples/interval-server.rs

@@ -22,7 +22,7 @@ async fn accept_connection(peer: SocketAddr, stream: TcpStream) {
 async fn handle_connection(peer: SocketAddr, stream: TcpStream) -> Result<()> {
     let ws_stream = accept_async(stream).await.expect("Failed to accept");
     info!("New WebSocket connection: {}", peer);
-    let (mut ws_sender, mut ws_receiver) = ws_stream.split();
+    let (ws_sender, mut ws_receiver) = ws_stream.split();
     let mut interval = async_std::stream::interval(Duration::from_millis(1000));
 
     // Echo incoming WebSocket messages and send a message periodically every second.

examples/tokio-client-bytes.rs

@@ -12,8 +12,6 @@
 
 use std::env;
 
-use futures::StreamExt;
-
 use async_tungstenite::tokio::connect_async;
 use async_tungstenite::{ByteReader, ByteWriter};
 use tokio::io;