code: @Benchmark
      public long jmhEventLoop(StreamObjects streamObjects) {
          final StreamMessage<Integer> stream = newStream(streamObjects);
          stream.subscribe(streamObjects.subscriber, EventLoopJmhExecutor.currentEventLoop());
          streamObjects.writeAllValues(stream);
          return streamObjects.computedSum();
      }
docs: deadlock.