diff options
| author | Yiyu Lin <linyiyu1992@gmail.com> | 2020-05-17 12:50:38 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-05-17 06:50:38 +0200 |
| commit | c4fe58d8df51e8f07142803ec0522f862fd30a3f (patch) | |
| tree | cd10811ffd740271cb0e510171198cf69221b570 /cli/ops | |
| parent | f12dffca9fbe0effb1a862ffd2854196d96d4af1 (diff) | |
Return error if more than one listener calls `WorkerHandle::get_event()` (#5461)
Diffstat (limited to 'cli/ops')
| -rw-r--r-- | cli/ops/worker_host.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cli/ops/worker_host.rs b/cli/ops/worker_host.rs index 479fcceaf..d1b4bb80f 100644 --- a/cli/ops/worker_host.rs +++ b/cli/ops/worker_host.rs @@ -306,7 +306,7 @@ fn op_host_get_message( }; let state_ = state.clone(); let op = async move { - let response = match worker_handle.get_event().await { + let response = match worker_handle.get_event().await? { Some(event) => { // Terminal error means that worker should be removed from worker table. if let WorkerEvent::TerminalError(_) = &event { |