Lines Matching refs:reserve
30 let permit = tx.reserve().await.unwrap(); in send_recv_with_buffer()
57 let permit1 = assert_ok!(tx1.reserve().await); in reserve_disarm()
58 let permit2 = assert_ok!(tx2.reserve().await); in reserve_disarm()
61 let mut r3 = task::spawn(tx3.reserve()); in reserve_disarm()
64 let mut r4 = task::spawn(tx4.reserve()); in reserve_disarm()
81 let mut r1 = task::spawn(tx1.reserve()); in reserve_disarm()
127 let mut r1 = Box::pin(tx1.reserve()); in start_send_past_cap()
131 let mut r2 = task::spawn(tx2.reserve()); in start_send_past_cap()
239 let p1 = assert_ok!(tx.reserve().await); in send_recv_buffer_limited()
245 let mut p2 = task::spawn(tx.reserve()); in send_recv_buffer_limited()
280 let permit1 = assert_ok!(tx1.reserve().await); in recv_close_gets_none_reserved()
281 let mut permit2 = task::spawn(tx2.reserve()); in recv_close_gets_none_reserved()
360 let permit = assert_ok!(tx1.reserve().await); in drop_permit_releases_permit()
362 let mut reserve2 = task::spawn(tx2.reserve()); in drop_permit_releases_permit()
379 assert_err!(tx.reserve().await); in dropping_rx_closes_channel()
465 let permit = assert_ok!(tx.reserve().await); in ready_close_cancel_bounded()
484 let permit1 = assert_ok!(tx1.reserve().await); in permit_available_not_acquired_close()
486 let mut permit2 = task::spawn(tx2.reserve()); in permit_available_not_acquired_close()