Skip to content

Commit f19216e

Browse files
committed
cargo fmt and cargo clippy
1 parent f49217a commit f19216e

File tree

3 files changed

+6
-10
lines changed

3 files changed

+6
-10
lines changed

homework/src/hello_server/cache.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ impl<K: Eq + Hash + Clone, V: Clone> Cache<K, V> {
7272
}
7373
let new_value = f(key);
7474
*value = Some(new_value.clone());
75-
return new_value;
75+
new_value
7676
}
7777
}
7878
}

homework/src/hello_server/tcp.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ impl CancellableTcpListener {
4141
self.is_canceled.store(true, Ordering::Release);
4242
let local_addr = self.inner.local_addr()?;
4343
let tcp_stream = TcpStream::connect(local_addr)?;
44-
44+
4545
Ok(())
4646
}
4747

homework/src/hello_server/thread_pool.rs

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -85,14 +85,10 @@ impl ThreadPool {
8585
let pool_inner = pool_inner.clone();
8686

8787
let thread = thread::spawn(move || {
88-
loop {
89-
if let Ok(job) = job_receiver.recv() {
90-
pool_inner.start_job();
91-
job.0();
92-
pool_inner.finish_job();
93-
} else {
94-
break;
95-
}
88+
while let Ok(job) = job_receiver.recv() {
89+
pool_inner.start_job();
90+
job.0();
91+
pool_inner.finish_job();
9692
}
9793
});
9894
_workers.push(Worker {

0 commit comments

Comments
 (0)