1 files changed, 6 insertions, 3 deletions

diff --git a/crates/thread_worker/src/lib.rs b/crates/thread_worker/src/lib.rs
index e558559ef..12e8bf17e 100644
--- a/crates/thread_worker/src/lib.rs
+++ b/crates/thread_worker/src/lib.rs
@@ -30,13 +30,16 @@ where
 impl<I, O> Worker<I, O> {
     /// Stops the worker. Returns the message receiver to fetch results which
     /// have become ready before the worker is stopped.
-    pub fn stop(self) -> Receiver<O> {
+    pub fn shutdown(self) -> Receiver<O> {
         self.out
     }
 
     pub fn send(&self, item: I) {
         self.inp.send(item)
     }
+    pub fn recv(&self) -> Option<O> {
+        self.out.recv()
+    }
 }
 
 impl WorkerHandle {
@@ -45,11 +48,11 @@ impl WorkerHandle {
         WorkerHandle {
             name,
             thread,
-            bomb: DropBomb::new(format!("WorkerHandle {} was not stopped", name)),
+            bomb: DropBomb::new(format!("WorkerHandle {} was not shutdown", name)),
         }
     }
 
-    pub fn stop(mut self) -> thread::Result<()> {
+    pub fn shutdown(mut self) -> thread::Result<()> {
         log::info!("waiting for {} to finish ...", self.name);
         let name = self.name;
         self.bomb.defuse();