Merge pull request #30 from qualified/permessage-deflate

Compress messages to reduce latency
qualified · Sep 13, 2021 · b3f6fe7 · b3f6fe7
2 parents a1b26b0 + 89fce50
commit b3f6fe7
Show file tree

Hide file tree

Showing 3 changed files with 47 additions and 57 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -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"

diff --git a/src/api/proxy.rs b/src/api/proxy.rs
@@ -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))
         })
 }