summaryrefslogtreecommitdiff
path: root/cli/web_worker.rs
diff options
context:
space:
mode:
authorYiyu Lin <linyiyu1992@gmail.com>2020-05-17 12:50:38 +0800
committerGitHub <noreply@github.com>2020-05-17 06:50:38 +0200
commitc4fe58d8df51e8f07142803ec0522f862fd30a3f (patch)
treecd10811ffd740271cb0e510171198cf69221b570 /cli/web_worker.rs
parentf12dffca9fbe0effb1a862ffd2854196d96d4af1 (diff)
Return error if more than one listener calls `WorkerHandle::get_event()` (#5461)
Diffstat (limited to 'cli/web_worker.rs')
-rw-r--r--cli/web_worker.rs8
1 files changed, 4 insertions, 4 deletions
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();
});