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

LongStream.onClose介绍

暂无

代码示例

代码示例来源：origin: speedment/speedment

@Override
public LongStream onClose(Runnable closeHandler) {
  return toStream().onClose(closeHandler);
}

代码示例来源：origin: ben-manes/caffeine

@Override
public LongStream events() throws IOException {
 DataInputStream input = new DataInputStream(new BufferedInputStream(readFiles()));
 LongStream stream = StreamSupport.longStream(Spliterators.spliteratorUnknownSize(
   new TraceIterator(input), Spliterator.ORDERED), /* parallel */ false);
 return stream.onClose(() -> Closeables.closeQuietly(input));
}

代码示例来源：origin: speedment/speedment

@Override
public LongStream onClose(Runnable closeHandler) {
  return wrap(stream().onClose(closeHandler));
}

代码示例来源：origin: google/guava

private void testMapWithIndex_longStream_closeIsPropagated(LongStream source) {
 AtomicInteger longStreamCloseCount = new AtomicInteger();
 LongStream longStream = source.onClose(longStreamCloseCount::incrementAndGet);
 Stream<String> withIndex = Streams.mapWithIndex(longStream, (str, i) -> str + ":" + i);
 withIndex.close();
 Truth.assertThat(longStreamCloseCount.get()).isEqualTo(1);
}

代码示例来源：origin: se.ugli.ugli-commons/ugli-commons

@Override
public LongStream onClose(final Runnable closeHandler) {
  return new LongResourceStream(stream.onClose(closeHandler), closeOnTerminalOperation, resources);
}

代码示例来源：origin: net.dongliu/commons-lang

@Override
public ExLongStream onClose(Runnable closeHandler) {
  return ExLongStream.of(stream.onClose(closeHandler));
}

代码示例来源：origin: com.github.ben-manes.caffeine/simulator

@Override
public LongStream events() throws IOException {
 DataInputStream input = new DataInputStream(new BufferedInputStream(readFiles()));
 LongStream stream = StreamSupport.longStream(Spliterators.spliteratorUnknownSize(
   new TraceIterator(input), Spliterator.ORDERED), /* parallel */ false);
 return stream.onClose(() -> Closeables.closeQuietly(input));
}

代码示例来源：origin: com.speedment.runtime/runtime-core

@Override
public LongStream onClose(Runnable closeHandler) {
  return wrap(stream().onClose(closeHandler));
}

代码示例来源：origin: org.neo4j/graph-algorithms-algo

/**
 * the resultStream(..) method starts the computation and
 * returns a Stream of SP-Tuples (source, target, minDist)
 *
 * @return the result stream
 */
@Override
public Stream<Result> resultStream() {
  counter.set(0);
  outputStreamOpen = true;
  for (int i = 0; i < concurrency; i++) {
    executorService.submit(new ShortestPathTask());
  }
  long end = (long) nodeCount * nodeCount;
  return LongStream.range(0, end)
      .onClose(() -> outputStreamOpen = false)
      .mapToObj(i -> {
        try {
          return resultQueue.take();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
      }).filter(result -> result.distance != Double.POSITIVE_INFINITY);
}

代码示例来源：origin: neo4j-contrib/neo4j-graph-algorithms

/**
 * the resultStream(..) method starts the computation and
 * returns a Stream of SP-Tuples (source, target, minDist)
 *
 * @return the result stream
 */
@Override
public Stream<Result> resultStream() {
  counter.set(0);
  outputStreamOpen = true;
  for (int i = 0; i < concurrency; i++) {
    executorService.submit(new ShortestPathTask());
  }
  long end = (long) nodeCount * nodeCount;
  return LongStream.range(0, end)
      .onClose(() -> outputStreamOpen = false)
      .mapToObj(i -> {
        try {
          return resultQueue.take();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
      }).filter(result -> result.distance != Double.POSITIVE_INFINITY);
}

代码示例来源：origin: com.google.guava/guava-tests

private void testMapWithIndex_longStream_closeIsPropagated(LongStream source) {
 AtomicInteger longStreamCloseCount = new AtomicInteger();
 LongStream longStream = source.onClose(longStreamCloseCount::incrementAndGet);
 Stream<String> withIndex = Streams.mapWithIndex(longStream, (str, i) -> str + ":" + i);
 withIndex.close();
 Truth.assertThat(longStreamCloseCount.get()).isEqualTo(1);
}