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

Method writeNullBytesFrom

protocol/encode.go:313–326  ·  view source on GitHub ↗
(b Bytes)

Source from the content-addressed store, hash-verified

311}
312
313func (e *encoder) writeNullBytesFrom(b Bytes) error {
314 if b == nil {
315 e.writeInt32(-1)
316 return nil
317 } else {
318 size := int64(b.Len())
319 e.writeInt32(int32(size))
320 n, err := io.Copy(e, b)
321 if err == nil && n != size {
322 err = fmt.Errorf("size of nullable bytes does not match the number of bytes that were written (size=%d, written=%d): %w", size, n, io.ErrUnexpectedEOF)
323 }
324 return err
325 }
326}
327
328func (e *encoder) writeVarNullBytesFrom(b Bytes) error {
329 if b == nil {

Callers 1

writeToVersion1Method · 0.95

Calls 2

writeInt32Method · 0.95
LenMethod · 0.65

Tested by

no test coverage detected