(cs *ClientStream)
| 2786 | } |
| 2787 | |
| 2788 | func newTestHTTP2Client(cs *ClientStream) *http2Client { |
| 2789 | return &http2Client{ |
| 2790 | activeStreams: map[uint32]*ClientStream{ |
| 2791 | 1: cs, |
| 2792 | }, |
| 2793 | controlBuf: newControlBuffer(make(<-chan struct{})), |
| 2794 | } |
| 2795 | } |
| 2796 | |
| 2797 | // TestClientDecodeHeader validates the handling of initial header frames that |
| 2798 | // do not signal the end of a stream. For all headers that indicate grpc content |
no test coverage detected