| 231 | } |
| 232 | |
| 233 | func (p *Peer) AssertEventuallyResponsesClosed(expectedError string) { |
| 234 | gotErr := false |
| 235 | p.t.Helper() |
| 236 | for { |
| 237 | err := p.readOneResp() |
| 238 | if xerrors.Is(err, errResponsesClosed) { |
| 239 | if !gotErr && expectedError != "" { |
| 240 | p.t.Errorf("responses closed without error '%s'", expectedError) |
| 241 | } |
| 242 | return |
| 243 | } |
| 244 | if err != nil && expectedError != "" && err.Error() == expectedError { |
| 245 | gotErr = true |
| 246 | continue |
| 247 | } |
| 248 | if !assert.NoError(p.t, err) { |
| 249 | return |
| 250 | } |
| 251 | } |
| 252 | } |
| 253 | |
| 254 | func (p *Peer) AssertNotClosed(d time.Duration) { |
| 255 | p.t.Helper() |