@@ -1127,8 +1127,8 @@ mod tests {
11271127 indexer_mailbox
11281128 . send_message ( ProcessedParquetBatch :: new_batches (
11291129 vec ! [
1130- create_test_batch_with_service_values( & vec! [ "a" ; 100 ] ) ,
1131- create_test_batch_with_service_values( & vec! [ "b" ; 10 ] ) ,
1130+ create_test_batch_with_service_values( & [ "a" ; 100 ] ) ,
1131+ create_test_batch_with_service_values( & [ "b" ; 10 ] ) ,
11321132 ] ,
11331133 SourceCheckpointDelta :: from_range ( 0 ..110 ) ,
11341134 false ,
@@ -1230,7 +1230,7 @@ mod tests {
12301230
12311231 indexer_mailbox
12321232 . send_message ( ProcessedParquetBatch :: new (
1233- create_test_batch_with_service_values ( & vec ! [ "a" ; 10 ] ) ,
1233+ create_test_batch_with_service_values ( & [ "a" ; 10 ] ) ,
12341234 SourceCheckpointDelta :: from_range ( 0 ..10 ) ,
12351235 false ,
12361236 ) )
@@ -1240,7 +1240,7 @@ mod tests {
12401240
12411241 indexer_mailbox
12421242 . send_message ( ProcessedParquetBatch :: new (
1243- create_test_batch_with_service_values ( & vec ! [ "b" ; 20 ] ) ,
1243+ create_test_batch_with_service_values ( & [ "b" ; 20 ] ) ,
12441244 SourceCheckpointDelta :: from_range ( 10 ..30 ) ,
12451245 true ,
12461246 ) )
@@ -1282,7 +1282,7 @@ mod tests {
12821282
12831283 indexer_mailbox
12841284 . send_message ( ProcessedParquetBatch :: new (
1285- create_test_batch_with_service_values ( & vec ! [ "a" ; 10 ] ) ,
1285+ create_test_batch_with_service_values ( & [ "a" ; 10 ] ) ,
12861286 SourceCheckpointDelta :: from_range ( 0 ..10 ) ,
12871287 false ,
12881288 ) )
@@ -1292,7 +1292,7 @@ mod tests {
12921292
12931293 indexer_mailbox
12941294 . send_message ( ProcessedParquetBatch :: new (
1295- create_test_batch_with_service_values ( & vec ! [ "b" ; 20 ] ) ,
1295+ create_test_batch_with_service_values ( & [ "b" ; 20 ] ) ,
12961296 SourceCheckpointDelta :: from_range ( 10 ..30 ) ,
12971297 false ,
12981298 ) )
@@ -1354,7 +1354,7 @@ mod tests {
13541354 let offset = idx as u64 ;
13551355 indexer_mailbox
13561356 . send_message ( ProcessedParquetBatch :: new (
1357- create_test_batch_with_service_values ( & vec ! [ service_value; 10 ] ) ,
1357+ create_test_batch_with_service_values ( & [ service_value; 10 ] ) ,
13581358 SourceCheckpointDelta :: from_range ( offset..offset + 1 ) ,
13591359 idx == 2 ,
13601360 ) )
@@ -1475,7 +1475,7 @@ mod tests {
14751475
14761476 indexer_mailbox
14771477 . send_message ( ProcessedParquetBatch :: new (
1478- create_test_batch_with_service_values ( & vec ! [ "a" ; 10 ] ) ,
1478+ create_test_batch_with_service_values ( & [ "a" ; 10 ] ) ,
14791479 SourceCheckpointDelta :: from_range ( 0 ..10 ) ,
14801480 false ,
14811481 ) )
@@ -1485,7 +1485,7 @@ mod tests {
14851485
14861486 indexer_mailbox
14871487 . send_message ( ProcessedParquetBatch :: new (
1488- create_test_batch_with_service_values ( & vec ! [ "b" ; 20 ] ) ,
1488+ create_test_batch_with_service_values ( & [ "b" ; 20 ] ) ,
14891489 SourceCheckpointDelta :: from_range ( 10 ..30 ) ,
14901490 true ,
14911491 ) )
0 commit comments