(
code opCode,
extras ...interface{})
| 778 | } |
| 779 | |
| 780 | func (c *RawBinaryClient) genericOp( |
| 781 | code opCode, |
| 782 | extras ...interface{}) Response { |
| 783 | |
| 784 | c.mutex.Lock() |
| 785 | defer c.mutex.Unlock() |
| 786 | |
| 787 | err := c.sendRequest(code, 0, nil, nil, extras...) |
| 788 | if err != nil { |
| 789 | return NewErrorResponse(err) |
| 790 | } |
| 791 | |
| 792 | status, _, _, _, err := c.receiveResponse(code) |
| 793 | if err != nil { |
| 794 | return NewErrorResponse(err) |
| 795 | } |
| 796 | return NewResponse(status) |
| 797 | } |
| 798 | |
| 799 | // See Client interface for documentation. |
| 800 | func (c *RawBinaryClient) Flush(expiration uint32) Response { |
no test coverage detected