fix Bench1Conn10kRequests crash

Motivation: `Bench1Conn10kRequests` performance tester incorrectly used a `NIOLoopBound` to access the `HTTP2StreamMultiplexer` to create streams. Modifications: Access the multiplexer by safely obtaining a reference to the handler. Result: - `Bench1Conn10kRequests` are not broken Co-authored-by: George Barnett <[email protected]>
apple · Jan 8, 2024 · 102df9e · 102df9e
1 parent 69e838f
commit 102df9e
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/Sources/NIOHTTP2PerformanceTester/Bench1Conn10kRequests.swift b/Sources/NIOHTTP2PerformanceTester/Bench1Conn10kRequests.swift
@@ -86,9 +86,8 @@ func sendOneRequest(channel: Channel, multiplexer: HTTP2StreamMultiplexer) throw
                                              ErrorHandler()],
                                             position: .last)
     }
-    let loopBoundMultiplexer = NIOLoopBound(multiplexer, eventLoop: channel.eventLoop)
-    channel.eventLoop.execute {
-        loopBoundMultiplexer.value.createStreamChannel(promise: nil, requestStreamInitializer)
+    channel.pipeline.handler(type: HTTP2StreamMultiplexer.self).whenSuccess { multiplexer in
+      multiplexer.createStreamChannel(promise: nil, requestStreamInitializer)
     }
     return try responseReceivedPromise.futureResult.wait()
 }