MCPcopy
hub / github.com/segmentio/kafka-go / Peek

Method Peek

protocol/conn.go:39–41  ·  view source on GitHub ↗
(n int)

Source from the content-addressed store, hash-verified

37}
38
39func (c *Conn) Peek(n int) ([]byte, error) {
40 return c.buffer.Peek(n)
41}
42
43func (c *Conn) Read(b []byte) (int, error) {
44 return c.buffer.Read(b)

Callers

nothing calls this directly

Calls 1

PeekMethod · 0.65

Tested by

no test coverage detected