Method Write

reverseproxy/reverseproxy.go:233–237

(p []byte)

}

func (m *maxLatencyWriter) Write(p []byte) (int, error) {
	m.Lock()
	defer m.Unlock()
	return m.dst.Write(p)
}

func (m *maxLatencyWriter) flushLoop() {
	t := time.NewTicker(m.latency)