We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f07e33d commit b635421Copy full SHA for b635421
rocketmq-common/src/common/thread/thread_service_tokio.rs
@@ -153,7 +153,7 @@ mod tests {
153
assert!(service_thread.started.load(Ordering::SeqCst));
154
assert!(!service_thread.stopped.load(Ordering::SeqCst));
155
156
- time::sleep(std::time::Duration::from_secs(100)).await;
+ time::sleep(std::time::Duration::from_secs(1)).await;
157
service_thread.shutdown_interrupt(false).await;
158
assert!(!service_thread.started.load(Ordering::SeqCst));
159
assert!(service_thread.stopped.load(Ordering::SeqCst));
0 commit comments