writing.go

func writing(outgoing *bufio.Writer, requests <-chan request, waiting chan request) (err error) {
	var req request
	var more = true
	for more && err == nil {
		select {
		case req, more = <-requests:
			waiting <- req // <- push req into another waiting channel
			_, err = outgoing.Write(req.body)
			continue
		default:
		}
		if err = outgoing.Flush(); err == nil {
			req, more = <-requests
			waiting <- req // <- push req into another waiting channel
			_, err = outgoing.Write(req.body)
		}
	}
	return err
}