Compress messages

Author: kazk

Cargo.lock

@@ -23,7 +23,7 @@ url = "2.2.2"
 
 tokio = { version = "1.6.1", features = ["fs", "process", "macros", "rt", "rt-multi-thread"] }
 tokio-util = { version = "0.6.7", features = ["codec"] }
-warp = { version = "0.3.1", default-features = false, features = ["websocket"] }
+warp = { git = "https://github.com/kazk/warp", branch = "permessage-deflate", default-features = false, features = ["websocket"] }
 
 tracing = "0.1.26"
 tracing-subscriber = "0.2.18"

Cargo.toml

@@ -44,7 +44,8 @@ pub fn handler(ctx: Context) -> impl Filter<Extract = impl Reply, Error = Reject
         .and(with_context(ctx))
         .and(with_optional_query())
         .map(|ws: warp::ws::Ws, ctx, query| {
-            ws.on_upgrade(move |socket| on_upgrade(socket, ctx, query))
+            ws.with_compression()
+                .on_upgrade(move |socket| on_upgrade(socket, ctx, query))
         })
 }