in Sources/NIOExtrasPerformanceTester/RollingPCAPPerformanceTest.swift [34:52]
func run() throws -> Int {
let channel = EmbeddedChannel()
defer {
_ = try! channel.finish()
}
let pcapRingBuffer = NIOPCAPRingBuffer(maximumFragments: 25,
maximumBytes: 1_000_000)
let pcapHandler = NIOWritePCAPHandler(mode: .client,
fileSink: pcapRingBuffer.addFragment)
try channel.pipeline.addHandler(pcapHandler, position: .first).wait()
for _ in 0 ..< self.numberOfRepeats {
channel.writeAndFlush(self.byteBuffer, promise: nil)
_ = try channel.readOutbound(as: ByteBuffer.self)
}
return self.numberOfRepeats
}