java.util.stream.DoubleStream.forEachOrdered()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(4.0k)|赞(0)|评价(0)|浏览(153)

本文整理了Java中java.util.stream.DoubleStream.forEachOrdered()方法的一些代码示例,展示了DoubleStream.forEachOrdered()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DoubleStream.forEachOrdered()方法的具体详情如下:
包路径:java.util.stream.DoubleStream
类名称:DoubleStream
方法名:forEachOrdered

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();
    } 
  }
}

相关文章