fix examples

Author: PDXKimani

example-messagepack/src/server.rs

@@ -34,6 +34,10 @@ async fn run_main() -> Result<(), Box<dyn std::error::Error>> {
             .unwrap_or_else(|_| "0.0.0.0:9000".to_string())
             .parse()?,
         DemoRpcSocketService,
+        4 << 20,
+        1 << 20,
+        128,
+        64 << 10,
     )
     .await?;
     server.set_max_queued_outbound_messages(512);

example-proto-tls/src/server.rs

@@ -68,7 +68,12 @@ async fn run_main() -> Result<(), Box<dyn std::error::Error>> {
             .parse()?,
         DemoRpcSocketService {
             tls_acceptor: Arc::new(server_config).into(),
+            
         },
+        4 << 20,
+        1 << 20,
+        128,
+        64 << 10,
     )
     .await?;
     server.set_max_queued_outbound_messages(512);

example-proto/src/server.rs

@@ -35,6 +35,10 @@ async fn run_main() -> Result<(), Box<dyn std::error::Error>> {
             .unwrap_or_else(|_| "0.0.0.0:9000".to_string())
             .parse()?,
         DemoRpcSocketService,
+        4 << 20,
+        1 << 20,
+        128,
+        64 << 10,
     )
     .await?;
     server.set_max_queued_outbound_messages(512);