Method ReadChunk

pkg/agent/proxy/fakeconn/fakeconn.go:208–219

ReadChunk returns the next Chunk from the underlying channel with timestamps intact. Bytes are returned without being copied into a caller buffer; parsers that want chunk-level timestamps (e.g. HTTP/2 frame parsers that care about per-frame arrival time) use this instead of Read. ReadChunk returns

()

// were drained from; callers should typically use Read XOR ReadChunk
// on a single FakeConn to avoid mixing the two.
func (f *FakeConn) ReadChunk() (Chunk, error) {
	if f.closed.Load() {
		// See Read: a chunk already delivered to f.ch (or stashed) is a
		// recorded wire event and must survive Close. Drain what is
		// buffered before reporting ErrClosed.
		if c, ok := f.drainBufferedLocked(); ok {
			return c, nil
		}
		return Chunk{}, ErrClosed
	}
	return f.readChunkLocked()
}

// drainBufferedLocked returns the next chunk that is ALREADY available
// without blocking: first any residual bytes left in the internal stash