Method Next

testing/go/regression/tool/message_reader.go:48–65

Next returns the next message, or nil if the reader has been exhausted.

()

// Next returns the next message, or nil if the reader has been exhausted.
func (mr *MessageReader) Next() pgproto3.Message {
	if len(mr.queue) > 0 {
		if len(mr.queue) == 1 {
			m := mr.queue[0]
			mr.queue = nil
			return m
		} else {
			m := mr.queue[0]
			mr.queue = mr.queue[1:]
			return m
		}
	}
	if mr.idx >= len(mr.messages) {
		return nil
	}
	mr.idx++
	return mr.messages[mr.idx-1]
}

// Peek returns the next message without moving the reader forward, or nil if the reader has been exhausted.
func (mr *MessageReader) Peek() pgproto3.Message {