Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
39
func
(c *Conn) Peek(n int) ([]byte, error) {
40
return
c.buffer.Peek(n)
41
}
42
43
func
(c *Conn) Read(b []byte) (int, error) {
44
return
c.buffer.Read(b)
Callers
nothing calls this directly
Calls
1
Peek
Method · 0.65
Tested by
no test coverage detected