38     let (tx, rx) = mpsc::channel(1);  in list()
40     Box::new(rx.then(|r| r.unwrap()))  in list()
44     let (tx, rx) = mpsc::channel(1);  in err_list()
46     Box::new(rx.then(|r| r.unwrap()))  in err_list()
173     let (tx, rx) = mpsc::channel(1);  in buffered()
181     let mut rx = rx.buffered(2);  in buffered()  localVariable
182     sassert_empty(&mut rx);  in buffered()
184     sassert_empty(&mut rx);  in buffered()
186     let mut rx = block_on_stream(rx);  in buffered()  localVariable
187     assert_eq!(rx.next(), Some(Ok(5)));  in buffered()
188     assert_eq!(rx.next(), Some(Ok(3)));  in buffered()
189     assert_eq!(rx.next(), None);  in buffered()
191     let (tx, rx) = mpsc::channel(1);  in buffered()
199     let mut rx = rx.buffered(1);  in buffered()  localVariable
200     sassert_empty(&mut rx);  in buffered()
202     sassert_empty(&mut rx);  in buffered()
204     let mut rx = block_on_stream(rx);  in buffered()  localVariable
205     assert_eq!(rx.next(), Some(Ok(5)));  in buffered()
206     assert_eq!(rx.next(), Some(Ok(3)));  in buffered()
207     assert_eq!(rx.next(), None);  in buffered()
212     let (tx, rx) = mpsc::channel(1);  in unordered()
220     let mut rx = rx.buffer_unordered(2);  in unordered()  localVariable
221     sassert_empty(&mut rx);  in unordered()
222     let mut rx = block_on_stream(rx);  in unordered()  localVariable
224     assert_eq!(rx.next(), Some(Ok(3)));  in unordered()
226     assert_eq!(rx.next(), Some(Ok(5)));  in unordered()
227     assert_eq!(rx.next(), None);  in unordered()
229     let (tx, rx) = mpsc::channel(1);  in unordered()
238     let mut rx = rx.buffer_unordered(1);  in unordered()  localVariable
239     sassert_empty(&mut rx);  in unordered()
241     sassert_empty(&mut rx);  in unordered()
243     let mut rx = block_on_stream(rx);  in unordered()  localVariable
244     assert_eq!(rx.next(), Some(Ok(5)));  in unordered()
245     assert_eq!(rx.next(), Some(Ok(3)));  in unordered()
246     assert_eq!(rx.next(), None);  in unordered()