Used to remove callbacks after error occurs in send().
(callbacks map[string]dnode.Path)
| 902 | |
| 903 | // Used to remove callbacks after error occurs in send(). |
| 904 | func (c *Client) removeCallbacks(callbacks map[string]dnode.Path) { |
| 905 | for sid := range callbacks { |
| 906 | // We don't check for error because we have created |
| 907 | // the callbacks map in the send function above. |
| 908 | // It does not come from remote, so cannot contain errors. |
| 909 | id, _ := strconv.ParseUint(sid, 10, 64) |
| 910 | c.scrubber.RemoveCallback(id) |
| 911 | } |
| 912 | } |
| 913 | |
| 914 | func (c *Client) config() *config.Config { |
| 915 | if c.Config != nil { |
no test coverage detected