Lines Matching refs:start_send
96 Pin::new(&mut inner).start_send(item.take().unwrap())?; in poll()
123 fn start_send(mut self: Pin<&mut Self>, item: Option<T>) -> Result<(), Self::Error> { in start_send() method
217 fn start_send(mut self: Pin<&mut Self>, item: T) -> Result<(), Self::Error> { in start_send() method
253 Pin::new(&mut s).start_send(0).unwrap(); in either_sink()
263 Pin::new(&mut v).start_send(0).unwrap(); in vec_sink()
264 Pin::new(&mut v).start_send(1).unwrap(); in vec_sink()
277 Pin::new(&mut deque).start_send(2).unwrap(); in vecdeque_sink()
278 Pin::new(&mut deque).start_send(3).unwrap(); in vecdeque_sink()
336 tx.start_send(0).unwrap(); in mpsc_blocking_start_send()
375 assert_eq!(Pin::new(&mut sink).start_send(0).ok(), Some(())); in with_flush()
443 assert_eq!(tx.as_mut().start_send(0), Ok(())); in with_propagates_poll_ready()
451 assert_eq!(tx.as_mut().start_send(1), Ok(())); in with_propagates_poll_ready()
471 Pin::new(&mut sink).start_send(Some(0)).unwrap(); in with_flush_propagate()
473 Pin::new(&mut sink).start_send(Some(1)).unwrap(); in with_flush_propagate()
637 assert_eq!(Pin::new(&mut tx).start_send(()), Ok(())); in sink_map_err()
643 Pin::new(&mut tx.sink_map_err(|_| ())).start_send(()), in sink_map_err()
666 assert_eq!(unfold.as_mut().start_send(1), Ok(())); in sink_unfold()
671 assert_eq!(unfold.as_mut().start_send(2), Ok(())); in sink_unfold()
673 assert_eq!(unfold.as_mut().start_send(3), Ok(())); in sink_unfold()
677 assert_eq!(unfold.as_mut().start_send(4), Ok(())); in sink_unfold()
707 assert_eq!(Pin::new(&mut tx).start_send(()), Ok(())); in err_into()
713 Pin::new(&mut tx.sink_err_into()).start_send(()), in err_into()