Method Write

core/http/middleware/node_header_integration_test.go:98–101

(b []byte)

}

func (o *orderRecorder) Write(b []byte) (int, error) {
	o.record(fmt.Sprintf("write:node=%s", o.Header().Get(middleware.NodeHeaderName)))
	return o.ResponseWriter.Write(b)
}

func (o *orderRecorder) Flush() {
	o.record(fmt.Sprintf("flush:node=%s", o.Header().Get(middleware.NodeHeaderName)))