File tree Expand file tree Collapse file tree 5 files changed +6
-6
lines changed
features/history_traversal/src Expand file tree Collapse file tree 5 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -187,7 +187,7 @@ impl WalHealer {
187
187
let healing_futures: Vec < ( _ , u64 ) > = queue_entries
188
188
. into_iter ( )
189
189
. sorted_by_key ( |entry| entry. blobstore_key . clone ( ) )
190
- . group_by ( |entry| entry. blobstore_key . clone ( ) )
190
+ . chunk_by ( |entry| entry. blobstore_key . clone ( ) )
191
191
. into_iter ( )
192
192
. map ( |( key, entries) | {
193
193
let entries: Vec < _ > = entries. into_iter ( ) . collect ( ) ;
Original file line number Diff line number Diff line change @@ -503,7 +503,7 @@ async fn process_deletion_nodes(
503
503
deleted_to_last_mapping. sort_by_key ( |( deleted_linknode, _) | * deleted_linknode) ;
504
504
deleted_to_last_mapping
505
505
. into_iter ( )
506
- . group_by ( |( deleted_linknode, _) | * * deleted_linknode)
506
+ . chunk_by ( |( deleted_linknode, _) | * * deleted_linknode)
507
507
. into_iter ( )
508
508
. for_each ( |( deleted_linknode, grouped_last) | {
509
509
history_graph. insert (
@@ -789,7 +789,7 @@ async fn augment_history_graph_insertions_with_mutable_ancestry(
789
789
graph_insertions. sort_unstable_by_key ( |( ( _, path) , _) | path. clone ( ) ) ;
790
790
let graph_insertions_by_path = graph_insertions
791
791
. into_iter ( )
792
- . group_by ( |( ( _, path) , _) | path. clone ( ) ) ;
792
+ . chunk_by ( |( ( _, path) , _) | path. clone ( ) ) ;
793
793
let graph_insertions_by_path = graph_insertions_by_path
794
794
. into_iter ( )
795
795
. map ( |( k, v) | ( k, v. collect :: < Vec < _ > > ( ) ) )
Original file line number Diff line number Diff line change @@ -615,7 +615,7 @@ async fn select_paths<I: Iterator<Item = PathHashBytes>>(
615
615
recorder : & PerfCounterRecorder < ' _ > ,
616
616
) -> Result < HashMap < PathHashBytes , PathBytes > , ErrorKind > {
617
617
let futs = iter
618
- . group_by ( |path_hash| connections. shard_id ( path_hash) )
618
+ . chunk_by ( |path_hash| connections. shard_id ( path_hash) )
619
619
. into_iter ( )
620
620
. map ( |( shard_id, group) | {
621
621
let group = group. collect :: < Vec < _ > > ( ) ;
Original file line number Diff line number Diff line change @@ -863,7 +863,7 @@ impl TailingWalkVisitor for WalkState {
863
863
. deferred_bcs
864
864
. iter ( )
865
865
. flat_map ( |e| e. value ( ) . clone ( ) )
866
- . group_by ( |e| e. label )
866
+ . chunk_by ( |e| e. label )
867
867
. into_iter ( )
868
868
. map ( |( key, group) | ( key, group. count ( ) ) )
869
869
. collect ( ) ;
Original file line number Diff line number Diff line change @@ -218,7 +218,7 @@ impl ValidatingVisitor {
218
218
) ,
219
219
checks_by_node_type : include_checks
220
220
. into_iter ( )
221
- . group_by ( |c| c. node_type ( ) )
221
+ . chunk_by ( |c| c. node_type ( ) )
222
222
. into_iter ( )
223
223
. map ( |( key, group) | ( key, HashSet :: from_iter ( group) ) )
224
224
. collect ( ) ,
You can’t perform that action at this time.
0 commit comments