chore(rpc): set message size to max for stream client (#12082)

risingwavelabs · Sep 5, 2023 · 9ccdbe3 · 9ccdbe3
1 parent 4f50903
commit 9ccdbe3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/rpc_client/src/stream_client.rs b/src/rpc_client/src/stream_client.rs
@@ -52,7 +52,9 @@ impl StreamClient {
             .await?
             .tracing_injected();
 
-        Ok(Self(StreamServiceClient::new(channel)))
+        Ok(Self(
+            StreamServiceClient::new(channel).max_decoding_message_size(usize::MAX),
+        ))
     }
 }