Lines Matching refs:Box
54 let send = Box::pin(caller_stream_tx.write_one("b".into())); in run()
83 let send = Box::pin(caller_stream_tx.write_one("d".into())); in run()
89 futures.push(Box::pin(send.map(|v| { in run()
91 })) as Pin<Box<dyn Future<Output = _>>>); in run()
92 futures.push(Box::pin( in run()
104 let send = Box::pin(caller_future_tx1.write("x".into())); in run()
139 let next = Box::pin(callee_stream_rx.read(Vec::with_capacity(1))); in run()
162 let next = Box::pin(callee_stream_rx.next()); in run()
168 futures.push(Box::pin(next.map(|v| { in run()
170 })) as Pin<Box<dyn Future<Output = _>>>); in run()
171 futures.push(Box::pin( in run()
183 let next = Box::pin(callee_future_rx1.into_future()); in run()
201 let send = Box::pin(caller_stream_tx.write_one("d".into())); in run()
206 let next = Box::pin(callee_stream_rx.next()); in run()
218 let next = Box::pin(callee_future_rx2.into_future()); in run()