diff --git a/src/grpc_subscription_autoreconnect.rs b/src/grpc_subscription_autoreconnect.rs index a9fb0fb..f744e66 100644 --- a/src/grpc_subscription_autoreconnect.rs +++ b/src/grpc_subscription_autoreconnect.rs @@ -214,7 +214,8 @@ pub fn create_geyser_reconnecting_stream( (ConnectionState::WaitReconnect(attempt), Message::Connecting(attempt)) }, Err(geyser_grpc_task_error) => { - panic!("! task aborted - should not happen :{geyser_grpc_task_error}"); + log::error!("! task aborted - should not happen :{geyser_grpc_task_error}"); + (ConnectionState::WaitReconnect(attempt), Message::Connecting(attempt)) } } @@ -234,7 +235,8 @@ pub fn create_geyser_reconnecting_stream( } None => { // should not arrive here, Mean the stream close. - panic!("geyser stream closed on {} - retrying", grpc_source); + log::error!("! ready stream closed"); + (ConnectionState::WaitReconnect(attempt), Message::Connecting(attempt)) } }