本文整理了Java中java.util.stream.DoubleStream.forEachOrdered()
方法的一些代码示例,展示了DoubleStream.forEachOrdered()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DoubleStream.forEachOrdered()
方法的具体详情如下:
包路径:java.util.stream.DoubleStream
类名称:DoubleStream
方法名:forEachOrdered
[英]Performs an action for each element of this stream, guaranteeing that each element is processed in encounter order for streams that have a defined encounter order.
This is a terminal operation.
[中]对该流的每个元素执行一个操作,确保每个元素都按照具有定义的相遇顺序的流的相遇顺序进行处理。
这是一个terminal operation。
代码示例来源:origin: speedment/speedment
@Override
public Void execute() {
try (final DoubleStream stream = buildPrevious()) {
stream.forEachOrdered(consumer);
}
return null;
}
}
代码示例来源:origin: speedment/speedment
default void forEachOrdered(DoublePipeline pipeline, DoubleConsumer action) {
requireNonNull(pipeline);
requireNonNull(action);
optimize(pipeline).getAsDoubleStream().forEachOrdered(action);
}
代码示例来源:origin: speedment/speedment
@Override
public void forEachOrdered(DoubleConsumer action) {
finallyClose(() -> stream().forEachOrdered(action));
}
代码示例来源:origin: prestodb/presto
@Override
public void serialize(DoubleStream stream, JsonGenerator jgen, SerializerProvider provider) throws IOException {
try(DoubleStream ds = stream) {
jgen.writeStartArray();
ds.forEachOrdered(value -> {
try {
jgen.writeNumber(value);
} catch (IOException e) {
throw new WrappedIOException(e);
}
});
jgen.writeEndArray();
} catch (WrappedIOException e) {
throw e.getCause();
}
}
}
代码示例来源:origin: ch.netzwerg/paleo-core
public Builder addAll(DoubleStream values) {
values.forEachOrdered(this::add);
return this;
}
代码示例来源:origin: net.dongliu/commons-lang
@Override
public void forEachOrdered(DoubleConsumer action) {
stream.forEachOrdered(action);
}
代码示例来源:origin: netzwerg/paleo
public Builder addAll(DoubleStream values) {
values.forEachOrdered(this::add);
return this;
}
代码示例来源:origin: se.ugli.ugli-commons/ugli-commons
@Override
public void forEachOrdered(final DoubleConsumer action) {
// This is a terminal operation
executeAndClose(() -> stream.forEachOrdered(action));
}
代码示例来源:origin: com.speedment.runtime/runtime-core
default void forEachOrdered(DoublePipeline pipeline, DoubleConsumer action) {
requireNonNull(pipeline);
requireNonNull(action);
optimize(pipeline).getAsDoubleStream().forEachOrdered(action);
}
代码示例来源:origin: apache/asterixdb
public static void put(ObjectNode o, String name, double[] elements) {
DoubleStream.of(elements).forEachOrdered(o.putArray(name)::add);
}
代码示例来源:origin: com.speedment.runtime/runtime-core
@Override
public void forEachOrdered(DoubleConsumer action) {
finallyClose(() -> stream().forEachOrdered(action));
}
代码示例来源:origin: one.util/streamex
@Override
public void forEachOrdered(DoubleConsumer action) {
if (spliterator != null && !isParallel()) {
spliterator().forEachRemaining(action);
} else {
if (context.fjp != null)
context.terminate(() -> {
stream().forEachOrdered(action);
return null;
});
else {
stream().forEachOrdered(action);
}
}
}
代码示例来源:origin: io.prestosql/presto-jdbc
@Override
public void serialize(DoubleStream stream, JsonGenerator jgen, SerializerProvider provider) throws IOException {
try(DoubleStream ds = stream) {
jgen.writeStartArray();
ds.forEachOrdered(value -> {
try {
jgen.writeNumber(value);
} catch (IOException e) {
throw new WrappedIOException(e);
}
});
jgen.writeEndArray();
} catch (WrappedIOException e) {
throw e.getCause();
}
}
}
代码示例来源:origin: com.facebook.presto/presto-jdbc
@Override
public void serialize(DoubleStream stream, JsonGenerator jgen, SerializerProvider provider) throws IOException {
try(DoubleStream ds = stream) {
jgen.writeStartArray();
ds.forEachOrdered(value -> {
try {
jgen.writeNumber(value);
} catch (IOException e) {
throw new WrappedIOException(e);
}
});
jgen.writeEndArray();
} catch (WrappedIOException e) {
throw e.getCause();
}
}
}
代码示例来源:origin: prestosql/presto
@Override
public void serialize(DoubleStream stream, JsonGenerator jgen, SerializerProvider provider) throws IOException {
try(DoubleStream ds = stream) {
jgen.writeStartArray();
ds.forEachOrdered(value -> {
try {
jgen.writeNumber(value);
} catch (IOException e) {
throw new WrappedIOException(e);
}
});
jgen.writeEndArray();
} catch (WrappedIOException e) {
throw e.getCause();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!