diff --git a/oximeter/collector/src/lib.rs b/oximeter/collector/src/lib.rs
index 29c6c4e3e91..4e2f6ca4fda 100644
--- a/oximeter/collector/src/lib.rs
+++ b/oximeter/collector/src/lib.rs
@@ -79,6 +79,7 @@ async fn collection_task(
                 match message {
                     None => {
                         debug!(log, "collection task inbox closed, shutting down");
+                        return;
                     }
                     Some(CollectionMessage::Shutdown) => {
                         debug!(log, "collection task received shutdown request");