From c4fe58d8df51e8f07142803ec0522f862fd30a3f Mon Sep 17 00:00:00 2001 From: Yiyu Lin Date: Sun, 17 May 2020 12:50:38 +0800 Subject: Return error if more than one listener calls `WorkerHandle::get_event()` (#5461) --- cli/web_worker.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'cli/web_worker.rs') diff --git a/cli/web_worker.rs b/cli/web_worker.rs index 490d9a5f3..46f03da36 100644 --- a/cli/web_worker.rs +++ b/cli/web_worker.rs @@ -300,13 +300,13 @@ mod tests { let r = handle.post_message(msg.clone()); assert!(r.is_ok()); - let maybe_msg = handle.get_event().await; + let maybe_msg = handle.get_event().await.unwrap(); assert!(maybe_msg.is_some()); let r = handle.post_message(msg.clone()); assert!(r.is_ok()); - let maybe_msg = handle.get_event().await; + let maybe_msg = handle.get_event().await.unwrap(); assert!(maybe_msg.is_some()); match maybe_msg { Some(WorkerEvent::Message(buf)) => { @@ -321,7 +321,7 @@ mod tests { .into_boxed_bytes(); let r = handle.post_message(msg); assert!(r.is_ok()); - let event = handle.get_event().await; + let event = handle.get_event().await.unwrap(); assert!(event.is_none()); handle.sender.close_channel(); }); @@ -348,7 +348,7 @@ mod tests { let msg = json!("hi").to_string().into_boxed_str().into_boxed_bytes(); let r = handle.post_message(msg.clone()); assert!(r.is_ok()); - let event = handle.get_event().await; + let event = handle.get_event().await.unwrap(); assert!(event.is_none()); handle.sender.close_channel(); }); -- cgit v1.2.3