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

Method SetDeadline

conn_test.go:84–88  ·  view source on GitHub ↗
(t time.Time)

Source from the content-addressed store, hash-verified

82}
83
84func (c *connPipe) SetDeadline(t time.Time) error {
85 c.rconn.SetDeadline(t)
86 c.wconn.SetDeadline(t)
87 return nil
88}
89
90func (c *connPipe) SetReadDeadline(t time.Time) error {
91 return c.rconn.SetReadDeadline(t)

Callers 3

testDeleteTopicsFunction · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected