Searched refs:DirectPipeConsumer (Results 1 – 1 of 1) sorted by relevance
65 pub struct DirectPipeConsumer<S>(S); struct68 for DirectPipeConsumer<S>151 reader.pipe(&mut store, DirectPipeConsumer(output_tx))?; in async_closed_streams()