func run()

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
    }