(other uuid.UUID)
| 217 | } |
| 218 | |
| 219 | func (p *Peer) AssertEventuallyLost(other uuid.UUID) { |
| 220 | p.t.Helper() |
| 221 | for { |
| 222 | o := p.peers[other] |
| 223 | if o.status == proto.CoordinateResponse_PeerUpdate_LOST { |
| 224 | return |
| 225 | } |
| 226 | if err := p.readOneResp(); err != nil { |
| 227 | assert.NoError(p.t, err) |
| 228 | return |
| 229 | } |
| 230 | } |
| 231 | } |
| 232 | |
| 233 | func (p *Peer) AssertEventuallyResponsesClosed(expectedError string) { |
| 234 | gotErr := false |