()
| 128 | } |
| 129 | |
| 130 | func (c *Client) Start() error { |
| 131 | c.mux.Lock() |
| 132 | defer c.mux.Unlock() |
| 133 | |
| 134 | c.running = true |
| 135 | c.send = make(chan []byte, clientSendBuffer) |
| 136 | c.done = make(chan struct{}) |
| 137 | |
| 138 | go c.runWatcher() |
| 139 | go c.clientReader() |
| 140 | go c.clientWriter() |
| 141 | |
| 142 | return nil |
| 143 | } |
| 144 | |
| 145 | func (c *Client) Write(msg []byte) (int, error) { |
| 146 | c.mux.Lock() |
no test coverage detected