(bytes []byte)
| 81 | } |
| 82 | |
| 83 | func (c channelWriter) Write(bytes []byte) (n int, err error) { |
| 84 | c.errChannel <- errors.New(strings.Trim(string(bytes), "\n")) |
| 85 | |
| 86 | return len(bytes), nil |
| 87 | } |
| 88 | |
| 89 | // cliRetryBackoff returns true for OnErr after sleeping the given interval for a limited number of times, |
| 90 | // and returns true for OnEmpty always. |
no outgoing calls
no test coverage detected