(c net.Conn, frameType FrameType, strm *Stream)
| 620 | } |
| 621 | |
| 622 | func (sc *serverConn) createStream(c net.Conn, frameType FrameType, strm *Stream) { |
| 623 | ctx := ctxPool.Get().(*fasthttp.RequestCtx) |
| 624 | ctx.Request.Reset() |
| 625 | ctx.Response.Reset() |
| 626 | |
| 627 | ctx.Init2(c, sc.logger, false) |
| 628 | |
| 629 | strm.origType = frameType |
| 630 | strm.startedAt = time.Now() |
| 631 | strm.SetData(ctx) |
| 632 | } |
| 633 | |
| 634 | func (sc *serverConn) handleFrame(strm *Stream, fr *FrameHeader) error { |
| 635 | err := sc.verifyState(strm, fr) |
no test coverage detected