Method WriteStreamObject

core/stream.go:337–426

WriteStreamObject writes a stream object to RDB file

(key string, stream *model.StreamObject, options ...interface{})

// WriteStreamObject writes a stream object to RDB file
func (enc *Encoder) WriteStreamObject(key string, stream *model.StreamObject, options ...interface{}) error {
	err := enc.beforeWriteObject(options...)
	if err != nil {
		return err
	}

	// Write stream type based on version
	var streamType byte
	switch stream.Version {
	case 1:
		streamType = typeStreamListPacks
	case 2:
		streamType = typeStreamListPacks2
	case 3:
		streamType = typeStreamListPacks3
	default:
		streamType = typeStreamListPacks // default to version 1
	}

	err = enc.write([]byte{streamType})
	if err != nil {
		return err
	}

	err = enc.writeString(key)
	if err != nil {
		return err
	}

	// Write stream entries
	err = enc.writeStreamEntries(stream.Entries)
	if err != nil {
		return err
	}

	// Write stream length
	err = enc.writeLength(stream.Length)
	if err != nil {
		return err
	}

	// Write last ID
	err = enc.writeStreamId(stream.LastId)
	if err != nil {
		return err
	}

	// Write version 2+ fields if available
	if stream.Version >= 2 {
		if stream.FirstId != nil {
			err = enc.writeStreamId(stream.FirstId)
			if err != nil {
				return err
			}
		} else {
			// Write zero ID if FirstId is nil
			err = enc.writeStreamId(&model.StreamId{Ms: 0, Sequence: 0})
			if err != nil {