下面列出了java.util.stream.IntStream#builder ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
private void refresh(LineBuffer update, int width) {
LineBuffer copy3 = new LineBuffer();
IntStream.Builder consumer = IntStream.builder();
copy3.insert(Helper.toCodePoints(currentPrompt));
copy3.insert(buffer().toArray());
copy3.setCursor(currentPrompt.length() + buffer().getCursor());
LineBuffer copy2 = new LineBuffer();
copy2.insert(Helper.toCodePoints(currentPrompt));
copy2.insert(update.toArray());
copy2.setCursor(currentPrompt.length() + update.getCursor());
copy3.update(copy2, data -> {
for (int cp : data) {
consumer.accept(cp);
}
}, width);
conn.stdoutHandler().accept(consumer.build().toArray());
buffer.clear();
buffer.insert(update.toArray());
buffer.setCursor(update.getCursor());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
private int[] intArray() throws StringTagParseException {
final IntStream.Builder builder = IntStream.builder();
while(this.buffer.hasMore()) {
final BinaryTag value = this.tag();
if(!(value instanceof IntBinaryTag)) {
throw this.buffer.makeError("All elements of an int array must be ints!");
}
builder.add(((IntBinaryTag) value).intValue());
if(this.separatorOrCompleteWith(Tokens.ARRAY_END)) {
return builder.build().toArray();
}
}
throw this.buffer.makeError("Reached end of document without array close");
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
private int[] intArray() throws StringTagParseException {
final IntStream.Builder builder = IntStream.builder();
while (this.buffer.hasMore()) {
final Tag value = this.tag();
if (!(value instanceof IntTag)) {
throw this.buffer.makeError("All elements of an int array must be ints!");
}
builder.add(((IntTag) value).getValue());
if (this.separatorOrCompleteWith(Tokens.ARRAY_END)) {
return builder.build().toArray();
}
}
throw this.buffer.makeError("Reached end of document without array close");
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
private IntStream buildSubstream() {
IntStream.Builder subBuilder = IntStream.builder() ;
for (int i = 0 ; i < grouping ; i++) {
subBuilder.add(buffer[(i + bufferReadIndex.get()) % buffer.length]) ;
}
bufferReadIndex.incrementAndGet() ;
return subBuilder.build() ;
}
@Override
public void accept(int t) {
if ((vals += vals < 3 ? 1 : 0) == 2) {
cons = IntStream.builder();
}
cons.accept(t);
}
@Test
public void testDropWhile() {
assertArrayEquals(new int[] { 5, 6, 7, 8, 9, 10, 11, 12, 13, 14 }, IntStreamEx.range(100).dropWhile(
i -> i % 10 < 5).limit(10).toArray());
assertEquals(100, IntStreamEx.range(100).dropWhile(i -> i % 10 < 0).count());
assertEquals(0, IntStreamEx.range(100).dropWhile(i -> i % 10 < 10).count());
assertEquals(OptionalInt.of(0), IntStreamEx.range(100).dropWhile(i -> i % 10 < 0).findFirst());
assertEquals(OptionalInt.empty(), IntStreamEx.range(100).dropWhile(i -> i % 10 < 10).findFirst());
java.util.Spliterator.OfInt spltr = IntStreamEx.range(100).dropWhile(i -> i % 10 < 1).spliterator();
assertTrue(spltr.tryAdvance((int x) -> assertEquals(1, x)));
Builder builder = IntStream.builder();
spltr.forEachRemaining(builder);
assertArrayEquals(IntStreamEx.range(2, 100).toArray(), builder.build().toArray());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
@Test(dataProvider = "sizes")
public void testIntAfterBuilding(int size) {
IntStream.Builder sb = IntStream.builder();
IntStream.range(0, size).forEach(sb);
sb.build();
checkISE(() -> sb.accept(1));
checkISE(() -> sb.add(1));
checkISE(() -> sb.build());
}
private Builder(IntColumnId id) {
this.id = id;
this.valueBuilder = IntStream.builder();
this.metaDataBuilder = new MetaDataBuilder();
}