Method XRead

structure/stream.go:198–232

XRead reads messages from a stream. Returns a slice of StreamMessage. Parameters: name: The name of the stream. count: The maximum number of messages to read. Returns: []StreamMessage: A slice of StreamMessage containing the read messages. error: An error if any occurred during the operation

(name string, count int)

//   - If the number of messages in the stream is less than count, it returns
//     ErrAmountOfData, indicating that there is not enough data in the stream.
func (s *StreamStructure) XRead(name string, count int) ([]StreamMessage, error) {
	if count <= 0 {
		return nil, ErrInvalidCount
	}

	// Get the stream
	encodedStreams, err := s.db.Get([]byte(name))
	if err != nil {
		return nil, err
	}

	// Decode the streams
	if err = s.decodeStreams(encodedStreams, s.streams); err != nil {
		return nil, err
	}

	// Get the messages
	messages := s.streams.Messages

	// Create a new slice of StreamMessage
	var result []StreamMessage

	// Get the messages
	if len(messages) >= count {
		messages = messages[:count]
		// Convert []*StreamMessage to []StreamMessage
		for _, msg := range messages {
			result = append(result, *msg)
		}
	} else {
		return nil, ErrAmountOfData
	}

	return result, nil
}

// XDel deletes a message from a stream.
// Returns true if the message was deleted.