12     let (send, mut recv) = channel(3);  in simple()
13     let mut send = PollSender::new(send);  in simple()  localVariable
16         let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in simple()
18         send.send_item(i).unwrap();  in simple()
21     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in simple()
30     send.send_item(42).unwrap();  in simple()
37     let (send, mut recv) = channel(3);  in simple_ref()
38     let mut send = PollSender::new(send);  in simple_ref()  localVariable
41         let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in simple_ref()
43         send.send_item(vi).unwrap();  in simple_ref()
46     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in simple_ref()
53     send.send_item(&42).unwrap();  in simple_ref()
58     let (send, mut recv) = channel::<i32>(1);  in repeated_poll_reserve()
59     let mut send = PollSender::new(send);  in repeated_poll_reserve()  localVariable
61     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in repeated_poll_reserve()
64     send.send_item(1).unwrap();  in repeated_poll_reserve()
71     let (send, mut recv) = channel(3);  in abort_send()
72     let mut send = PollSender::new(send);  in abort_send()  localVariable
73     let send2 = send.get_ref().cloned().unwrap();  in abort_send()
76         let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in abort_send()
78         send.send_item(i).unwrap();  in abort_send()
81     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in abort_send()
87     let mut send2_send = spawn(send2.send(5));  in abort_send()
89     assert!(send.abort_send());  in abort_send()
100     let (send, mut recv) = channel::<i32>(3);  in close_sender_last()
101     let mut send = PollSender::new(send);  in close_sender_last()  localVariable
106     send.close();  in close_sender_last()
114     let (send, mut recv) = channel::<i32>(3);  in close_sender_not_last()
115     let mut send = PollSender::new(send);  in close_sender_not_last()  localVariable
116     let send2 = send.get_ref().cloned().unwrap();  in close_sender_not_last()
121     send.close();  in close_sender_not_last()
134     let (send, mut recv) = channel::<i32>(3);  in close_sender_before_reserve()
135     let mut send = PollSender::new(send);  in close_sender_before_reserve()  localVariable
140     send.close();  in close_sender_before_reserve()
145     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in close_sender_before_reserve()
151     let (send, mut recv) = channel::<i32>(1);  in close_sender_after_pending_reserve()
152     let mut send = PollSender::new(send);  in close_sender_after_pending_reserve()  localVariable
157     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in close_sender_after_pending_reserve()
159     send.send_item(1).unwrap();  in close_sender_after_pending_reserve()
163     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in close_sender_after_pending_reserve()
167     send.close();  in close_sender_after_pending_reserve()
169     assert!(send.is_closed());  in close_sender_after_pending_reserve()
170     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in close_sender_after_pending_reserve()
176     let (send, mut recv) = channel::<i32>(3);  in close_sender_after_successful_reserve()
177     let mut send = PollSender::new(send);  in close_sender_after_successful_reserve()  localVariable
182     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in close_sender_after_successful_reserve()
186     send.close();  in close_sender_after_successful_reserve()
187     assert!(send.is_closed());  in close_sender_after_successful_reserve()
191     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in close_sender_after_successful_reserve()
197     let (send, mut recv) = channel::<i32>(1);  in abort_send_after_pending_reserve()
198     let mut send = PollSender::new(send);  in abort_send_after_pending_reserve()  localVariable
203     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in abort_send_after_pending_reserve()
205     send.send_item(1).unwrap();  in abort_send_after_pending_reserve()
207     assert_eq!(send.get_ref().unwrap().capacity(), 0);  in abort_send_after_pending_reserve()
208     assert!(!send.abort_send());  in abort_send_after_pending_reserve()
210     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in abort_send_after_pending_reserve()
213     assert!(send.abort_send());  in abort_send_after_pending_reserve()
214     assert_eq!(send.get_ref().unwrap().capacity(), 0);  in abort_send_after_pending_reserve()
219     let (send, mut recv) = channel::<i32>(1);  in abort_send_after_successful_reserve()
220     let mut send = PollSender::new(send);  in abort_send_after_successful_reserve()  localVariable
225     assert_eq!(send.get_ref().unwrap().capacity(), 1);  in abort_send_after_successful_reserve()
226     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in abort_send_after_successful_reserve()
228     assert_eq!(send.get_ref().unwrap().capacity(), 0);  in abort_send_after_successful_reserve()
230     assert!(send.abort_send());  in abort_send_after_successful_reserve()
231     assert_eq!(send.get_ref().unwrap().capacity(), 1);  in abort_send_after_successful_reserve()
236     let (send, _) = channel::<i32>(1);  in closed_when_receiver_drops()
237     let mut send = PollSender::new(send);  in closed_when_receiver_drops()  localVariable
239     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in closed_when_receiver_drops()
246     let (send, _) = channel::<i32>(3);  in start_send_panics_when_idle()
247     let mut send = PollSender::new(send);  in start_send_panics_when_idle()  localVariable
249     send.send_item(1).unwrap();  in start_send_panics_when_idle()
255     let (send, _) = channel::<i32>(1);  in start_send_panics_when_acquiring()
256     let mut send = PollSender::new(send);  in start_send_panics_when_acquiring()  localVariable
258     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in start_send_panics_when_acquiring()
260     send.send_item(1).unwrap();  in start_send_panics_when_acquiring()
262     let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx)));  in start_send_panics_when_acquiring()
264     send.send_item(2).unwrap();  in start_send_panics_when_acquiring()
269     let (send, mut recv) = channel(1);  in sink_send_then_flush()
270     let mut send = PollSender::new(send);  in sink_send_then_flush()  localVariable
275     let mut ready = spawn(poll_fn(|cx| send.poll_ready_unpin(cx)));  in sink_send_then_flush()
277     assert_ok!(send.start_send_unpin(()));  in sink_send_then_flush()
279     let mut ready = spawn(poll_fn(|cx| send.poll_ready_unpin(cx)));  in sink_send_then_flush()
282     let mut flush = spawn(poll_fn(|cx| send.poll_flush_unpin(cx)));  in sink_send_then_flush()
286     let mut ready = spawn(poll_fn(|cx| send.poll_ready_unpin(cx)));  in sink_send_then_flush()
296     let (send, mut recv) = channel(1);  in sink_send_then_close()
297     let mut send = PollSender::new(send);  in sink_send_then_close()  localVariable
302     let mut ready = spawn(poll_fn(|cx| send.poll_ready_unpin(cx)));  in sink_send_then_close()
304     assert_ok!(send.start_send_unpin(1));  in sink_send_then_close()
306     let mut ready = spawn(poll_fn(|cx| send.poll_ready_unpin(cx)));  in sink_send_then_close()
318     assert_ok!(send.start_send_unpin(2));  in sink_send_then_close()
320     let mut close = spawn(poll_fn(|cx| send.poll_close_unpin(cx)));  in sink_send_then_close()
334     let (send, mut recv) = channel(1);  in sink_send_ref()
335     let mut send = PollSender::new(send);  in sink_send_ref()  localVariable
340     let mut ready = spawn(poll_fn(|cx| send.poll_ready_unpin(cx)));  in sink_send_ref()
343     assert_ok!(send.start_send_unpin(data.as_str()));  in sink_send_ref()
345     let mut flush = spawn(poll_fn(|cx| send.poll_flush_unpin(cx)));  in sink_send_ref()