Searched refs:sink_map_err (Results 1 – 4 of 4) sorted by relevance
11 let tx = tx1.fanout(tx2).sink_map_err(|_| ()); in it_works()
626 fn sink_map_err() { in sink_map_err() function636 let mut tx = tx.sink_map_err(|_| ()); in sink_map_err()643 Pin::new(&mut tx.sink_map_err(|_| ())).start_send(()), in sink_map_err()
22 sink: SinkExt::sink_map_err(sink, Into::into), in new()
143 fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> in sink_map_err() method