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

Function hasResponse

protocol/roundtrip.go:25–28  ·  view source on GitHub ↗
(msg Message)

Source from the content-addressed store, hash-verified

23}
24
25func hasResponse(msg Message) bool {
26 x, _ := msg.(interface{ HasResponse() bool })
27 return x == nil || x.HasResponse()
28}

Callers 1

RoundTripFunction · 0.85

Calls 1

HasResponseMethod · 0.45

Tested by

no test coverage detected