From 9e2c1c19086b1035b6e3ce3e73e1e0aa6d0119f7 Mon Sep 17 00:00:00 2001 From: Bryan Chen Date: Mon, 2 Dec 2024 13:52:18 +1300 Subject: [PATCH] fix --- src/server.rs | 1 + src/tests/merge_subscription.rs | 1 + src/tests/upstream.rs | 1 + 3 files changed, 3 insertions(+) diff --git a/src/server.rs b/src/server.rs index 6bf2f0c..05b29d6 100644 --- a/src/server.rs +++ b/src/server.rs @@ -259,6 +259,7 @@ mod tests { listen_address: "127.0.0.1".to_string(), port, max_connections: 1024, + max_subscriptions_per_connection: 1024, max_batch_size, request_timeout_seconds: request_timeout_seconds.unwrap_or(10), http_methods: Vec::new(), diff --git a/src/tests/merge_subscription.rs b/src/tests/merge_subscription.rs index 21ed046..558d820 100644 --- a/src/tests/merge_subscription.rs +++ b/src/tests/merge_subscription.rs @@ -54,6 +54,7 @@ async fn merge_subscription_works() { listen_address: "0.0.0.0".to_string(), port: 0, max_connections: 10, + max_subscriptions_per_connection: 1024, max_batch_size: None, request_timeout_seconds: 120, http_methods: Vec::new(), diff --git a/src/tests/upstream.rs b/src/tests/upstream.rs index 8a78a90..2afc10e 100644 --- a/src/tests/upstream.rs +++ b/src/tests/upstream.rs @@ -36,6 +36,7 @@ async fn upstream_error_propagate() { listen_address: "0.0.0.0".to_string(), port: 0, max_connections: 10, + max_subscriptions_per_connection: 1024, max_batch_size: None, request_timeout_seconds: 120, http_methods: Vec::new(),