| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/indicatif-0.16.2/src/ |
| H A D | rayon.rs | 45 let consumer = ProgressConsumer::new(consumer, self.progress); in drive()
119 struct ProgressConsumer<C> { struct
124 impl<C> ProgressConsumer<C> { impl
126 ProgressConsumer { base, progress } in new()
130 impl<T, C: Consumer<T>> Consumer<T> for ProgressConsumer<C> { implementation
138 ProgressConsumer::new(left, self.progress.clone()), in split_at()
139 ProgressConsumer::new(right, self.progress), in split_at()
156 impl<T, C: UnindexedConsumer<T>> UnindexedConsumer<T> for ProgressConsumer<C> { implementation
158 ProgressConsumer::new(self.base.split_off_left(), self.progress.clone()) in split_off_left()
195 let consumer1 = ProgressConsumer::new(consumer, self.progress.clone()); in drive_unindexed()
|
| /dports/www/xh/xh-0.14.1/cargo-crates/indicatif-0.16.2/src/ |
| H A D | rayon.rs | 45 let consumer = ProgressConsumer::new(consumer, self.progress); in drive()
119 struct ProgressConsumer<C> { struct
124 impl<C> ProgressConsumer<C> { impl
126 ProgressConsumer { base, progress } in new()
130 impl<T, C: Consumer<T>> Consumer<T> for ProgressConsumer<C> { implementation
138 ProgressConsumer::new(left, self.progress.clone()), in split_at()
139 ProgressConsumer::new(right, self.progress), in split_at()
156 impl<T, C: UnindexedConsumer<T>> UnindexedConsumer<T> for ProgressConsumer<C> { implementation
158 ProgressConsumer::new(self.base.split_off_left(), self.progress.clone()) in split_off_left()
195 let consumer1 = ProgressConsumer::new(consumer, self.progress.clone()); in drive_unindexed()
|
| /dports/benchmarks/hyperfine/hyperfine-1.12.0/cargo-crates/indicatif-0.16.2/src/ |
| H A D | rayon.rs | 45 let consumer = ProgressConsumer::new(consumer, self.progress); in drive()
119 struct ProgressConsumer<C> { struct
124 impl<C> ProgressConsumer<C> { argument
126 ProgressConsumer { base, progress } in new()
130 impl<T, C: Consumer<T>> Consumer<T> for ProgressConsumer<C> { implementation
138 ProgressConsumer::new(left, self.progress.clone()), in split_at()
139 ProgressConsumer::new(right, self.progress), in split_at()
156 impl<T, C: UnindexedConsumer<T>> UnindexedConsumer<T> for ProgressConsumer<C> { implementation
158 ProgressConsumer::new(self.base.split_off_left(), self.progress.clone()) in split_off_left()
195 let consumer1 = ProgressConsumer::new(consumer, self.progress.clone()); in drive_unindexed()
|
| /dports/devel/sentry-cli/sentry-cli-1.71.0/cargo-crates/indicatif-0.14.0/src/ |
| H A D | iter.rs | 96 struct ProgressConsumer<C> { struct
101 impl<C> ProgressConsumer<C> { implementation
103 ProgressConsumer { base, progress } in new()
107 impl<T, C: Consumer<T>> Consumer<T> for ProgressConsumer<C> { implementation
115 ProgressConsumer::new(left, self.progress.clone()), in split_at()
116 ProgressConsumer::new(right, self.progress.clone()), in split_at()
133 impl<T, C: UnindexedConsumer<T>> UnindexedConsumer<T> for ProgressConsumer<C> { implementation
135 ProgressConsumer::new(self.base.split_off_left(), self.progress.clone()) in split_off_left()
172 let consumer1 = ProgressConsumer::new(consumer, self.progress.clone()); in drive_unindexed()
|
| /dports/textproc/angle-grinder/angle-grinder-0.18.0/cargo-crates/indicatif-0.13.0/src/ |
| H A D | iter.rs | 96 struct ProgressConsumer<C> { struct
101 impl<C> ProgressConsumer<C> { implementation
103 ProgressConsumer { base, progress } in new()
107 impl<T, C: Consumer<T>> Consumer<T> for ProgressConsumer<C> { implementation
115 ProgressConsumer::new(left, self.progress.clone()), in split_at()
116 ProgressConsumer::new(right, self.progress.clone()), in split_at()
133 impl<T, C: UnindexedConsumer<T>> UnindexedConsumer<T> for ProgressConsumer<C> { implementation
135 ProgressConsumer::new(self.base.split_off_left(), self.progress.clone()) in split_off_left()
172 let consumer1 = ProgressConsumer::new(consumer, self.progress.clone()); in drive_unindexed()
|
| /dports/textproc/cast2gif/cast2gif-0.1.0/cargo-crates/indicatif-0.14.0/src/ |
| H A D | iter.rs | 96 struct ProgressConsumer<C> { struct
101 impl<C> ProgressConsumer<C> { impl
103 ProgressConsumer { base, progress } in new()
107 impl<T, C: Consumer<T>> Consumer<T> for ProgressConsumer<C> { implementation
115 ProgressConsumer::new(left, self.progress.clone()), in split_at()
116 ProgressConsumer::new(right, self.progress.clone()), in split_at()
133 impl<T, C: UnindexedConsumer<T>> UnindexedConsumer<T> for ProgressConsumer<C> { implementation
135 ProgressConsumer::new(self.base.split_off_left(), self.progress.clone()) in split_off_left()
172 let consumer1 = ProgressConsumer::new(consumer, self.progress.clone()); in drive_unindexed()
|
| /dports/devel/py-celery-progress/celery-progress-0.1.1/celery_progress/websockets/ |
| H A D | routing.py | 6 …progress_consumer = consumers.ProgressConsumer.as_asgi() # New in Channels 3, works similar to Dj…
8 …progress_consumer = consumers.ProgressConsumer # Channels 3 not installed, revert to Channels 2 b…
|
| H A D | consumers.py | 8 class ProgressConsumer(AsyncWebsocketConsumer): class
|