diff --git a/examples/autobahn-server.rs b/examples/autobahn-server.rs
index 42eddf5..3f570e8 100644
--- a/examples/autobahn-server.rs
+++ b/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 {
diff --git a/examples/client.rs b/examples/client.rs
index 2a28e42..bf5f1bb 100644
--- a/examples/client.rs
+++ b/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()
diff --git a/examples/interval-server.rs b/examples/interval-server.rs
index 55e7a0b..9874dd3 100644
--- a/examples/interval-server.rs
+++ b/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 {
diff --git a/examples/server.rs b/examples/server.rs
index 8bb66de..747fefd 100644
--- a/examples/server.rs
+++ b/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>>>;