Lines Matching refs:async

78         rt.block_on(async {
90         let out = rt.block_on(async {
108         let out = rt.block_on(async {
111             tokio::spawn(async move {
125         let out = rt.block_on(async {
128             let handle = tokio::spawn(async move {
148         let out = rt.block_on(async {
152             tokio::spawn(async move {
156             tokio::spawn(async move {
175         let out = rt.block_on(async {
183                     tokio::spawn(async move {
225         let out = rt.block_on(async {
226             tokio::spawn(async move {
242                         tokio::spawn(async move {
281         let out = rt.block_on(async {
282             assert_ok!(tokio::spawn(async {
283                 assert_ok!(tokio::spawn(async {
298         rt.block_on(async {
320         rt1.block_on(async { rt2.block_on(async { "hello" }) });
326         let rt2 = rt1.block_on(async { rt() });
327         let out = rt2.block_on(async { "ZOMG" });
336         rt.block_on(async {
340             tokio::spawn(async {
359         rt.block_on(async {
364             tokio::spawn(async {
375             tokio::spawn(async move {
394             handle.spawn(async move {
399         rt.block_on(async move {
412             handle.spawn(async move {
417         rt.block_on(async move {
419             tokio::spawn(async {
436         rt.block_on(async move {
450         rt.block_on(async move {
453             tokio::spawn(async move {
468         rt.block_on(async move {
474             tokio::spawn(async move {
488         let out = rt.block_on(async move {
490                 tokio::spawn(async move { "hello" })
503         let out = rt.block_on(async move {
518         rt.block_on(async move {
525                 futures::executor::block_on(async {
538         rt.block_on(async move {
545                 futures::executor::block_on(async {
569                 rt.block_on(async move {
577             rt2.block_on(async move {
608             rt.spawn(async {
616         rt.block_on(async {
620             let srv = tokio::spawn(async move {
625             let cli = tokio::spawn(async move {
643         rt.block_on(async move { client_server(tx).await });
680         rt.block_on(async { panic!() });
683     async fn yield_once() {
702             tokio::spawn(async {})
735         rt.block_on(async move {
736             tokio::spawn(async move {
770         rt.spawn(async move {
776         rt.spawn(async move {
786                 h1.spawn(async move {
793         rt.spawn(async move {
801         rt.block_on(async {
817             runtime.block_on(async {
823                 tokio::spawn(async move {
831                 tokio::spawn(async move {
849         runtime.block_on(async move {
865         runtime.block_on(async move {
880         runtime.block_on(async move {
911     async fn client_server(tx: mpsc::Sender<()>) {
918         tokio::spawn(async move {
940         local.block_on(&rt, async move {
946             task::spawn_local(async move {
963         local.block_on(&rt, async move { client_server_local(tx).await });
969     async fn client_server_local(tx: mpsc::Sender<()>) {
976         task::spawn_local(async move {
999         rt.block_on(async {
1002                 tokio::spawn(async { })
1027         rt.block_on(async {
1030                 tokio::spawn(async { })
1060         rt.block_on(async {
1071                 tasks.push(task::spawn(async move {
1085                 tasks.push(task::spawn(async move {
1097             let handle = task::spawn(async {