(strs ...string)
| 2195 | } |
| 2196 | |
| 2197 | func (w *natsWriter) writeDirect(strs ...string) error { |
| 2198 | for _, str := range strs { |
| 2199 | if _, err := w.w.Write([]byte(str)); err != nil { |
| 2200 | return err |
| 2201 | } |
| 2202 | } |
| 2203 | return nil |
| 2204 | } |
| 2205 | |
| 2206 | func (w *natsWriter) flush() error { |
| 2207 | // If a pending buffer is set, we don't flush. Code that needs to |
no test coverage detected