Searched refs:DirectPipeProducer (Results 1 – 1 of 1) sorted by relevance
29 pub struct DirectPipeProducer<S>(S); struct31 impl<D, S: Stream<Item = u8> + Send + 'static> StreamProducer<D> for DirectPipeProducer<S> { implementation146 StreamReader::new(&mut store, DirectPipeProducer(input_rx))? in async_closed_streams()