Lines Matching refs:and_then
40 .and_then(|tx| tx.send(Ok(2))) in list()
41 .and_then(|tx| tx.send(Ok(3))) in list()
49 .and_then(|tx| tx.send(Ok(2))) in err_list()
50 .and_then(|tx| tx.send(Err(3))) in err_list()
102 fn and_then() { in and_then() function
103 assert_done(|| list().and_then(|a| Ok(a + 1)).collect(), Ok(vec![2, 3, 4])); in and_then()
104 assert_done(|| list().and_then(|a| err::<i32, u32>(a as u32)).collect::<Vec<_>>(), in and_then()
197 .and_then(|tx| tx.send(Box::new(d.map_err(|_| panic!())))) in buffered()
215 .and_then(|tx| tx.send(Box::new(d.map_err(|_| panic!())))) in buffered()
236 .and_then(|tx| tx.send(Box::new(d.recover(|_| panic!())))) in unordered()
253 .and_then(|tx| tx.send(Box::new(d.recover(|_| panic!())))) in unordered()