Lines Matching full:send
9 let (send, mut recv) = channel(3); in simple()
10 let mut send = PollSender::new(send); in simple() localVariable
13 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in simple()
15 send.send_item(i).unwrap(); in simple()
18 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in simple()
27 send.send_item(42).unwrap(); in simple()
34 let (send, mut recv) = channel(3); in simple_ref()
35 let mut send = PollSender::new(send); in simple_ref() localVariable
38 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in simple_ref()
40 send.send_item(vi).unwrap(); in simple_ref()
43 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in simple_ref()
50 send.send_item(&42).unwrap(); in simple_ref()
55 let (send, mut recv) = channel::<i32>(1); in repeated_poll_reserve()
56 let mut send = PollSender::new(send); in repeated_poll_reserve() localVariable
58 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in repeated_poll_reserve()
61 send.send_item(1).unwrap(); in repeated_poll_reserve()
68 let (send, mut recv) = channel(3); in abort_send()
69 let mut send = PollSender::new(send); in abort_send() localVariable
70 let send2 = send.get_ref().cloned().unwrap(); in abort_send()
73 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send()
75 send.send_item(i).unwrap(); in abort_send()
78 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send()
84 let mut send2_send = spawn(send2.send(5)); in abort_send()
86 assert!(send.abort_send()); in abort_send()
97 let (send, mut recv) = channel::<i32>(3); in close_sender_last()
98 let mut send = PollSender::new(send); in close_sender_last() localVariable
103 send.close(); in close_sender_last()
111 let (send, mut recv) = channel::<i32>(3); in close_sender_not_last()
112 let mut send = PollSender::new(send); in close_sender_not_last() localVariable
113 let send2 = send.get_ref().cloned().unwrap(); in close_sender_not_last()
118 send.close(); in close_sender_not_last()
131 let (send, mut recv) = channel::<i32>(3); in close_sender_before_reserve()
132 let mut send = PollSender::new(send); in close_sender_before_reserve() localVariable
137 send.close(); in close_sender_before_reserve()
142 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_before_reserve()
148 let (send, mut recv) = channel::<i32>(1); in close_sender_after_pending_reserve()
149 let mut send = PollSender::new(send); in close_sender_after_pending_reserve() localVariable
154 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_pending_reserve()
156 send.send_item(1).unwrap(); in close_sender_after_pending_reserve()
160 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_pending_reserve()
164 send.close(); in close_sender_after_pending_reserve()
166 assert!(send.is_closed()); in close_sender_after_pending_reserve()
167 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_pending_reserve()
173 let (send, mut recv) = channel::<i32>(3); in close_sender_after_successful_reserve()
174 let mut send = PollSender::new(send); in close_sender_after_successful_reserve() localVariable
179 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_successful_reserve()
183 send.close(); in close_sender_after_successful_reserve()
184 assert!(send.is_closed()); in close_sender_after_successful_reserve()
188 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in close_sender_after_successful_reserve()
194 let (send, mut recv) = channel::<i32>(1); in abort_send_after_pending_reserve()
195 let mut send = PollSender::new(send); in abort_send_after_pending_reserve() localVariable
200 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send_after_pending_reserve()
202 send.send_item(1).unwrap(); in abort_send_after_pending_reserve()
204 assert_eq!(send.get_ref().unwrap().capacity(), 0); in abort_send_after_pending_reserve()
205 assert!(!send.abort_send()); in abort_send_after_pending_reserve()
207 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send_after_pending_reserve()
210 assert!(send.abort_send()); in abort_send_after_pending_reserve()
211 assert_eq!(send.get_ref().unwrap().capacity(), 0); in abort_send_after_pending_reserve()
216 let (send, mut recv) = channel::<i32>(1); in abort_send_after_successful_reserve()
217 let mut send = PollSender::new(send); in abort_send_after_successful_reserve() localVariable
222 assert_eq!(send.get_ref().unwrap().capacity(), 1); in abort_send_after_successful_reserve()
223 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in abort_send_after_successful_reserve()
225 assert_eq!(send.get_ref().unwrap().capacity(), 0); in abort_send_after_successful_reserve()
227 assert!(send.abort_send()); in abort_send_after_successful_reserve()
228 assert_eq!(send.get_ref().unwrap().capacity(), 1); in abort_send_after_successful_reserve()
233 let (send, _) = channel::<i32>(1); in closed_when_receiver_drops()
234 let mut send = PollSender::new(send); in closed_when_receiver_drops() localVariable
236 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in closed_when_receiver_drops()
243 let (send, _) = channel::<i32>(3); in start_send_panics_when_idle()
244 let mut send = PollSender::new(send); in start_send_panics_when_idle() localVariable
246 send.send_item(1).unwrap(); in start_send_panics_when_idle()
252 let (send, _) = channel::<i32>(1); in start_send_panics_when_acquiring()
253 let mut send = PollSender::new(send); in start_send_panics_when_acquiring() localVariable
255 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in start_send_panics_when_acquiring()
257 send.send_item(1).unwrap(); in start_send_panics_when_acquiring()
259 let mut reserve = spawn(poll_fn(|cx| send.poll_reserve(cx))); in start_send_panics_when_acquiring()
261 send.send_item(2).unwrap(); in start_send_panics_when_acquiring()