Lines Matching refs:OP
29 fn execute<I, OP, FromA, FromB>(pi: I, op: OP) -> (FromA, FromB) in execute() argument
32 OP: UnzipOp<I::Item>, in execute()
33 FromA: Default + Send + ParallelExtend<OP::Left>, in execute()
34 FromB: Default + Send + ParallelExtend<OP::Right>, in execute()
43 fn execute_into<I, OP, FromA, FromB>(a: &mut FromA, b: &mut FromB, pi: I, op: OP) in execute_into() argument
46 OP: UnzipOp<I::Item>, in execute_into()
47 FromA: Send + ParallelExtend<OP::Left>, in execute_into()
48 FromB: Send + ParallelExtend<OP::Right>, in execute_into()
194 struct UnzipA<'b, I, OP, FromB> {
196 op: OP,
200 impl<'b, I, OP, FromB> ParallelIterator for UnzipA<'b, I, OP, FromB>
203 OP: UnzipOp<I::Item>,
204 FromB: Send + ParallelExtend<OP::Right>,
206 type Item = OP::Left;
230 if OP::indexable() { in opt_len()
239 struct UnzipB<'r, I, OP, CA>
242 OP: UnzipOp<I::Item>,
243 CA: UnindexedConsumer<OP::Left>,
247 op: OP,
252 impl<'r, I, OP, CA> ParallelIterator for UnzipB<'r, I, OP, CA>
255 OP: UnzipOp<I::Item>,
256 CA: UnindexedConsumer<OP::Left>,
258 type Item = OP::Right;
277 if OP::indexable() { in opt_len()
286 struct UnzipConsumer<'a, OP, CA, CB> {
287 op: &'a OP,
292 impl<'a, T, OP, CA, CB> Consumer<T> for UnzipConsumer<'a, OP, CA, CB>
294 OP: UnzipOp<T>,
295 CA: Consumer<OP::Left>,
296 CB: Consumer<OP::Right>,
298 type Folder = UnzipFolder<'a, OP, CA::Folder, CB::Folder>;
338 impl<'a, T, OP, CA, CB> UnindexedConsumer<T> for UnzipConsumer<'a, OP, CA, CB>
340 OP: UnzipOp<T>,
341 CA: UnindexedConsumer<OP::Left>,
342 CB: UnindexedConsumer<OP::Right>,
361 struct UnzipFolder<'a, OP, FA, FB> {
362 op: &'a OP,
367 impl<'a, T, OP, FA, FB> Folder<T> for UnzipFolder<'a, OP, FA, FB>
369 OP: UnzipOp<T>,
370 FA: Folder<OP::Left>,
371 FB: Folder<OP::Right>,