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 f9e88e6 commit 8a28434Copy full SHA for 8a28434
src/ucp/endpoint/am.rs
@@ -620,12 +620,12 @@ mod tests {
620
let protos = vec![None, Some(AmProto::Eager), Some(AmProto::Rndv)];
621
for block_size_shift in 0..20_usize {
622
for p in protos.iter() {
623
- let rt = tokio::runtime::Builder::new_current_thread()
624
- .enable_time()
625
- .build()
626
- .unwrap();
627
- let local = tokio::task::LocalSet::new();
628
- local.block_on(&rt, send_recv(4 << block_size_shift, *p));
+ let rt = tokio::runtime::Builder::new_current_thread()
+ .enable_time()
+ .build()
+ .unwrap();
+ let local = tokio::task::LocalSet::new();
+ local.block_on(&rt, send_recv(4 << block_size_shift, *p));
629
}
630
631
0 commit comments