(req leaveGroupRequestV0)
| 607 | } |
| 608 | |
| 609 | func (t *timeoutCoordinator) leaveGroup(req leaveGroupRequestV0) (leaveGroupResponseV0, error) { |
| 610 | if err := t.conn.SetDeadline(time.Now().Add(t.timeout)); err != nil { |
| 611 | return leaveGroupResponseV0{}, err |
| 612 | } |
| 613 | return t.conn.leaveGroup(req) |
| 614 | } |
| 615 | |
| 616 | func (t *timeoutCoordinator) heartbeat(req heartbeatRequestV0) (heartbeatResponseV0, error) { |
| 617 | if err := t.conn.SetDeadline(time.Now().Add(t.timeout)); err != nil { |
nothing calls this directly
no test coverage detected