use re-expored tungstenite

examples/autobahn-server.rs

@@ -1,8 +1,10 @@
 use async_std::net::{SocketAddr, TcpListener, TcpStream};
-use async_tungstenite::{accept_async, tungstenite::Error};
+use async_tungstenite::{
+    accept_async,
+    tungstenite::{Error, Result},
+};
 use futures::prelude::*;
 use log::*;
-use tungstenite::Result;
 
 async fn accept_connection(peer: SocketAddr, stream: TcpStream) {
     if let Err(e) = handle_connection(peer, stream).await {

examples/client.rs

@@ -13,12 +13,12 @@
 use std::env;
 
 use futures::{future, pin_mut, StreamExt};
-use tungstenite::protocol::Message;
 
 use async_std::io;
 use async_std::prelude::*;
 use async_std::task;
 use async_tungstenite::async_std::connect_async;
+use async_tungstenite::tungstenite::protocol::Message;
 
 async fn run() {
     let connect_addr = env::args()

examples/interval-server.rs

@@ -1,12 +1,14 @@
 use async_std::net::{TcpListener, TcpStream};
 use async_std::task;
-use async_tungstenite::{accept_async, tungstenite::Error};
+use async_tungstenite::{
+    accept_async,
+    tungstenite::{Error, Message, Result},
+};
 use futures::future::{select, Either};
 use futures::prelude::*;
 use log::*;
 use std::net::SocketAddr;
 use std::time::Duration;
-use tungstenite::{Message, Result};
 
 async fn accept_connection(peer: SocketAddr, stream: TcpStream) {
     if let Err(e) = handle_connection(peer, stream).await {

examples/server.rs

@@ -33,7 +33,7 @@ use futures::{
 
 use async_std::net::{TcpListener, TcpStream};
 use async_std::task;
-use tungstenite::protocol::Message;
+use async_tungstenite::tungstenite::protocol::Message;
 
 type Tx = UnboundedSender<Message>;
 type PeerMap = Arc<Mutex<HashMap<SocketAddr, Tx>>>;