Searched refs:ParDrainProducer (Results 1 – 1 of 1) sorted by relevance
106 let producer = ParDrainProducer { iter }; in drive_unindexed()141 let producer = ParDrainProducer { iter }; in drive_unindexed()155 struct ParDrainProducer<T> { struct159 impl<T: Send> UnindexedProducer for ParDrainProducer<T> { argument166 let left = ParDrainProducer { iter: left }; in split()167 let right = right.map(|right| ParDrainProducer { iter: right }); in split()191 impl<T> Drop for ParDrainProducer<T> { implementation