Method writeStreamEntries

core/stream.go:438–462

writeStreamEntries writes stream entries

(entries []*model.StreamEntry)

// writeStreamEntries writes stream entries
func (enc *Encoder) writeStreamEntries(entries []*model.StreamEntry) error {
	err := enc.writeLength(uint64(len(entries)))
	if err != nil {
		return err
	}

	for _, entry := range entries {
		// Write entry header (first message ID)
		header := make([]byte, 16)
		binary.BigEndian.PutUint64(header[0:8], entry.FirstMsgId.Ms)
		binary.BigEndian.PutUint64(header[8:16], entry.FirstMsgId.Sequence)
		err = enc.writeString(unsafeBytes2Str(header))
		if err != nil {
			return err
		}

		// Write entry content as listpack
		err = enc.writeStreamEntryContent(entry)
		if err != nil {
			return err
		}
	}

	return nil
}

// writeStreamEntryContent writes a stream entry content as listpack
func (enc *Encoder) writeStreamEntryContent(entry *model.StreamEntry) error {