Skip to content

Commit aa7c914

Browse files
author
Rishabh Kumar
committed
OAK-11451 : reverted code changes for Iterables.concat with Iterable<Iterable<E>> from oak-segment
1 parent 0c99171 commit aa7c914

File tree

1 file changed

+3
-4
lines changed
  • oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment

1 file changed

+3
-4
lines changed

oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/MapRecord.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import static java.lang.Integer.highestOneBit;
2323
import static java.lang.Integer.numberOfTrailingZeros;
2424
import static java.util.Objects.requireNonNull;
25+
import static org.apache.jackrabbit.guava.common.collect.Iterables.concat;
2526
import static org.apache.jackrabbit.oak.segment.MapEntry.newMapEntry;
2627

2728
import java.util.ArrayList;
@@ -30,8 +31,6 @@
3031
import java.util.Iterator;
3132
import java.util.List;
3233
import java.util.Objects;
33-
import java.util.stream.Collectors;
34-
import java.util.stream.StreamSupport;
3534

3635
import org.apache.jackrabbit.guava.common.collect.ComparisonChain;
3736
import org.apache.jackrabbit.oak.commons.collections.IteratorUtils;
@@ -338,7 +337,7 @@ public Iterator<String> iterator() {
338337
}
339338
});
340339
}
341-
return IteratorUtils.toIterable(keys.stream().flatMap(StreamUtils::toStream).iterator());
340+
return concat(keys);
342341
}
343342

344343
RecordId[] ids = new RecordId[size];
@@ -388,7 +387,7 @@ public Iterator<MapEntry> iterator() {
388387
}
389388
});
390389
}
391-
return IteratorUtils.toIterable(entries.stream().flatMap(StreamUtils::toStream).iterator());
390+
return concat(entries);
392391
}
393392

394393
MapEntry[] entries = new MapEntry[size];

0 commit comments

Comments
 (0)