@Benchmark
    public List<Integer> collectDirect(StreamObjects streamObjects) {
        final StreamMessage<Integer> stream = newStream(streamObjects);
        streamObjects.writeAllValues(stream);
        return stream.collect(ImmediateEventExecutor.INSTANCE).join();
    }
Micro benchmarks of {@link StreamMessage#collect()}.
benchmarks/jmh/src/jmh/java/com/linecorp/armeria/common/stream/StreamMessageCollectorBenchmark.java