Searched refs:NeverWriteStreamProducer (Results 1 – 1 of 1) sorted by relevance
1152 let reader = StreamReader::new(&mut store, NeverWriteStreamProducer)?; in stream_cancel_read_async_does_not_corrupt_state()1157 struct NeverWriteStreamProducer; in stream_cancel_read_async_does_not_corrupt_state() struct1159 impl StreamProducer<()> for NeverWriteStreamProducer { in stream_cancel_read_async_does_not_corrupt_state() implementation