Skip to content

Commit 8b6a1fb

Browse files
authored
fix: remove the timeout so that the stream stops prematurely ending (#552)
1 parent c9b5d6b commit 8b6a1fb

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

xmtp_api_grpc/src/grpc_api_helper.rs

-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@ async fn create_tls_channel(address: String) -> Result<Channel, Error> {
3333
.map_err(|e| Error::new(ErrorKind::SetupError).with(e))?
3434
.keep_alive_while_idle(true)
3535
.connect_timeout(Duration::from_secs(5))
36-
.http2_keep_alive_interval(Duration::from_secs(10))
3736
.keep_alive_timeout(Duration::from_secs(25))
3837
.tls_config(ClientTlsConfig::new())
3938
.map_err(|e| Error::new(ErrorKind::SetupError).with(e))?

xmtp_api_grpc/src/lib.rs

+2-2
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,7 @@ mod tests {
249249
#[tokio::test]
250250
async fn long_lived_subscribe_test() {
251251
let auth_token = get_auth_token();
252-
tokio::time::timeout(std::time::Duration::from_secs(30), async move {
252+
tokio::time::timeout(std::time::Duration::from_secs(100), async move {
253253
let client = Client::create(DEV_ADDRESS.to_string(), true).await.unwrap();
254254

255255
let topic = uuid::Uuid::new_v4();
@@ -278,7 +278,7 @@ mod tests {
278278
panic!("Message 1 Error: {}", err);
279279
}
280280

281-
tokio::time::sleep(std::time::Duration::from_secs(15)).await;
281+
tokio::time::sleep(std::time::Duration::from_secs(50)).await;
282282
client
283283
.publish(
284284
auth_token.to_string(),

0 commit comments

Comments
 (0)