We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4481e57 commit 968842cCopy full SHA for 968842c
src/io_loop.rs
@@ -26,7 +26,7 @@ use std::{
26
thread::Builder as ThreadBuilder,
27
time::Duration,
28
};
29
-use tracing::{Level, error, trace};
+use tracing::{Level, debug, error, trace};
30
31
const FRAMES_STORAGE: usize = 32;
32
@@ -231,6 +231,11 @@ impl<
231
break (stream, res);
232
}
233
234
+ // FIXME: make this configurable and/or smarter?
235
+ let throttle = 1000;
236
+ debug!("Throttling {}ms before reconnection to avoid flooding", throttle);
237
+ std::thread::sleep(std::time::Duration::from_millis(throttle));
238
+
239
self.reset();
240
self.socket_state.reset();
241
self.internal_rpc.start_channels_recovery();
0 commit comments