executor: return error when reply channel is closed unexectedly

1 files changed, 6 insertions, 1 deletions

diff --git a/src/executor.rs b/src/executor.rs
index 99a2804..39e262d 100644
--- a/src/executor.rs
+++ b/src/executor.rs
@@ -303,7 +303,12 @@ impl<'ctx> Executor<'ctx> {
 						progress = true;
 					}
 					ipc::IpcSelectionResult::ChannelClosed(id) => {
-						self.tasks_running.remove(&id);
+						if let Some(task) = self.tasks_running.remove(&id) {
+							return Err(Error::new(format!(
+								"Unexpectedly got no result for task {:#}",
+								task
+							)));
+						}
 					}
 				}
 			}