(match string)
| 293 | } |
| 294 | |
| 295 | func (p *Peer) AssertEventuallyGetsError(match string) { |
| 296 | p.t.Helper() |
| 297 | for { |
| 298 | err := p.readOneResp() |
| 299 | if xerrors.Is(err, errResponsesClosed) { |
| 300 | p.t.Error("closed before target error") |
| 301 | return |
| 302 | } |
| 303 | |
| 304 | if err != nil && assert.ErrorContains(p.t, err, match) { |
| 305 | return |
| 306 | } |
| 307 | } |
| 308 | } |
| 309 | |
| 310 | // AssertNeverUpdateKind asserts that we have not received |
| 311 | // any updates on the provided peer for the provided kind. |
no test coverage detected