futures_tokio_compat is not needed anymore.

Cargo.lock

  "env_logger 0.7.1 (registry+https://github.com/rust-lang/crates.io-index)",
  "fswatcher 0.1.0 (git+https://github.com/mgottschlag/fswatcher-rs.git)",
  "futures 0.3.1 (registry+https://github.com/rust-lang/crates.io-index)",
- "futures-tokio-compat 0.1.0 (git+https://github.com/mgottschlag/futures-tokio-compat.git)",
  "log 0.4.8 (registry+https://github.com/rust-lang/crates.io-index)",
  "rmp-serde 0.14.3 (registry+https://github.com/rust-lang/crates.io-index)",
  "serde 1.0.104 (registry+https://github.com/rust-lang/crates.io-index)",

Cargo.toml

 byteorder = "1.3"
 tokio = { version = "0.2", features = ["fs", "io-util", "macros", "net", "rt-threaded", "stream", "sync", "tcp", "time"] }
 futures = "0.3.1"
-futures-tokio-compat = { git = "https://github.com/mgottschlag/futures-tokio-compat.git" }
 async-tungstenite = { version = "0.3", features = ["tokio-runtime"] }
 env_logger = "0.7"
 log = "0.4"

src/bin/server.rs

 use std::sync::{Arc, Mutex};
 
 use async_tungstenite::accept_async;
+use async_tungstenite::tokio::TokioAdapter;
 use futures::sink::SinkExt;
-use futures_tokio_compat::Compat;
 use log::*;
 use tokio::net::{TcpListener, TcpStream};
 use tokio::stream::StreamExt;
 // TODO: Robust error handling.
 
 async fn accept_connection(peer: SocketAddr, stream: TcpStream) {
-    let mut ws_stream = accept_async(Compat::new(stream))
+    let mut ws_stream = accept_async(TokioAdapter(stream))
         .await
         .expect("Failed to accept");