IsEmpty returns true when all messages have been returned.
()
| 41 | |
| 42 | // IsEmpty returns true when all messages have been returned. |
| 43 | func (mr *MessageReader) IsEmpty() bool { |
| 44 | return len(mr.queue) == 0 && mr.idx >= len(mr.messages) |
| 45 | } |
| 46 | |
| 47 | // Next returns the next message, or nil if the reader has been exhausted. |
| 48 | func (mr *MessageReader) Next() pgproto3.Message { |
no outgoing calls