code review cleanup
JP Robinson
7 years ago
| 139 | 139 | e.mgr.Put(err) |
| 140 | 140 | } |
| 141 | 141 | |
| 142 | func (e *Emitter) flush(conn io.Writer) error { | |
| 143 | w := bufio.NewWriter(conn) | |
| 142 | func (e *Emitter) flush(w io.Writer) error { | |
| 143 | bw := bufio.NewWriter(w) | |
| 144 | 144 | |
| 145 | 145 | for _, c := range e.counters { |
| 146 | c.flush(w, e.prefix) | |
| 146 | c.flush(bw, e.prefix) | |
| 147 | 147 | } |
| 148 | 148 | |
| 149 | 149 | for _, h := range e.histograms { |
| 150 | h.flush(w, e.prefix) | |
| 150 | h.flush(bw, e.prefix) | |
| 151 | 151 | } |
| 152 | 152 | |
| 153 | 153 | for _, g := range e.gauges { |
| 154 | g.flush(w, e.prefix) | |
| 154 | g.flush(bw, e.prefix) | |
| 155 | 155 | } |
| 156 | 156 | |
| 157 | return w.Flush() | |
| 157 | return bw.Flush() | |
| 158 | 158 | } |