@Benchmark
    public long notJmhEventLoop(StreamObjects streamObjects) throws Exception {
        final StreamMessage<Integer> stream = newStream(streamObjects);
        ANOTHER_EVENT_LOOP.execute(() -> {
            stream.subscribe(streamObjects.subscriber, ANOTHER_EVENT_LOOP);
            streamObjects.writeAllValues(stream);
        });
        return streamObjects.computedSum(stream);
    }
Microbenchmarks of {@link StreamMessage Stream Messages}.
benchmarks/jmh/src/jmh/java/com/linecorp/armeria/common/stream/StreamMessageBenchmark.java