diff --git a/src/compute_thread.rs b/src/compute_thread.rs
index 683deaf..bb8a4d1 100644
--- a/src/compute_thread.rs
+++ b/src/compute_thread.rs
@@ -153,7 +153,10 @@ impl ComputeThread
             Ok(val) =>
             {
                // Found a message.
-               self.continue_running = !val;
+               if !val == false
+               {
+                  self.change_state(ThreadState::Finished);
+               }
             }
 
             Err(error) =>