diff --git a/Sources/NIOHTTP2PerformanceTester/Bench1Conn10kRequests.swift b/Sources/NIOHTTP2PerformanceTester/Bench1Conn10kRequests.swift index 1c81b1b1..0a371c74 100644 --- 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() }