MCPcopy
hub / github.com/IBM/sarama / downgradeFlexibleEncoder

Function downgradeFlexibleEncoder

encoder_decoder.go:146–155  ·  view source on GitHub ↗
(pe packetEncoder)

Source from the content-addressed store, hash-verified

144}
145
146func downgradeFlexibleEncoder(pe packetEncoder) packetEncoder {
147 switch pe := pe.(type) {
148 case *prepFlexibleEncoder:
149 return pe.prepEncoder
150 case *realFlexibleEncoder:
151 return pe.realEncoder
152 default:
153 return pe
154 }
155}

Callers 1

encodeMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected