(t *testing.T)
| 286 | synctest.Test(t, testConnCloseUnblocksStreamWrite) |
| 287 | } |
| 288 | func testConnCloseUnblocksStreamWrite(t *testing.T) { |
| 289 | testConnCloseUnblocks(t, func(ctx context.Context, tc *testConn) error { |
| 290 | s := newLocalStream(t, tc, bidiStream) |
| 291 | s.SetWriteContext(ctx) |
| 292 | buf := make([]byte, 32) |
| 293 | _, err := s.Write(buf) |
| 294 | return err |
| 295 | }, permissiveTransportParameters, func(c *Config) { |
| 296 | c.MaxStreamWriteBufferSize = 16 |
| 297 | }) |
| 298 | } |
| 299 | |
| 300 | func TestConnCloseUnblocksStreamClose(t *testing.T) { |
| 301 | synctest.Test(t, testConnCloseUnblocksStreamClose) |
nothing calls this directly
no test coverage detected
searching dependent graphs…