Method call

builder_test.go:245–252

call is a convenience method that allows the kafkaWriteBuffer to be used in a functional manner. This is helpful when building nested structures, as the return value can be fed into other fwWB APIs.

(cb func(wb *kafkaWriteBuffer))

// nested structures, as the return value can be fed into
// other fwWB APIs.
func (f *kafkaWriteBuffer) call(cb func(wb *kafkaWriteBuffer)) []byte {
	cb(f)
	bs := f.Bytes()
	if bs == nil {
		bs = []byte{}
	}
	return bs
}

func mustCompress(bs []byte, codec compress.Codec) (res []byte) {
	buf := bytes.Buffer{}