summaryrefslogtreecommitdiffstats
path: root/vendor/tokio/tests/task_builder.rs
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/tokio/tests/task_builder.rs')
-rw-r--r--vendor/tokio/tests/task_builder.rs20
1 files changed, 17 insertions, 3 deletions
diff --git a/vendor/tokio/tests/task_builder.rs b/vendor/tokio/tests/task_builder.rs
index 1499abf19..78329ff26 100644
--- a/vendor/tokio/tests/task_builder.rs
+++ b/vendor/tokio/tests/task_builder.rs
@@ -11,6 +11,7 @@ mod tests {
let result = Builder::new()
.name("name")
.spawn(async { "task executed" })
+ .unwrap()
.await;
assert_eq!(result.unwrap(), "task executed");
@@ -21,6 +22,7 @@ mod tests {
let result = Builder::new()
.name("name")
.spawn_blocking(|| "task executed")
+ .unwrap()
.await;
assert_eq!(result.unwrap(), "task executed");
@@ -34,6 +36,7 @@ mod tests {
Builder::new()
.name("name")
.spawn_local(async move { unsend_data })
+ .unwrap()
.await
})
.await;
@@ -43,14 +46,20 @@ mod tests {
#[test]
async fn spawn_without_name() {
- let result = Builder::new().spawn(async { "task executed" }).await;
+ let result = Builder::new()
+ .spawn(async { "task executed" })
+ .unwrap()
+ .await;
assert_eq!(result.unwrap(), "task executed");
}
#[test]
async fn spawn_blocking_without_name() {
- let result = Builder::new().spawn_blocking(|| "task executed").await;
+ let result = Builder::new()
+ .spawn_blocking(|| "task executed")
+ .unwrap()
+ .await;
assert_eq!(result.unwrap(), "task executed");
}
@@ -59,7 +68,12 @@ mod tests {
async fn spawn_local_without_name() {
let unsend_data = Rc::new("task executed");
let result = LocalSet::new()
- .run_until(async move { Builder::new().spawn_local(async move { unsend_data }).await })
+ .run_until(async move {
+ Builder::new()
+ .spawn_local(async move { unsend_data })
+ .unwrap()
+ .await
+ })
.await;
assert_eq!(*result.unwrap(), "task executed");