class Async::HTTP::Body::Slowloris
def write(chunk)
def write(chunk) if @last_chunk_size time_since_last_write = Async::Clock.now - @last_write_at throughput = @last_chunk_size / time_since_last_write if throughput < @minimum_throughput error = ThroughputError.new(throughput, @minimum_throughput, time_since_last_write) self.close(error) end end super.tap do @last_write_at = Async::Clock.now @last_chunk_size = chunk&.bytesize end end