code: func NewLogEntryDecoder(r io.Reader) LogEntryDecoder {
  	return &logEntryDecoder{
  		lenBuf: make([]byte, binaryEncodeLen),
  		buf:    make([]byte, 1024),
  		r:      r,
  	}
  }
docs: // NewLogEntryDecoder creates a new stream decoder for log entries