(subject, reqID string)
| 3208 | } |
| 3209 | |
| 3210 | func subjectMatchesReqID(subject, reqID string) bool { |
| 3211 | subjectParts := strings.Split(subject, ".") |
| 3212 | if len(subjectParts) < 2 { |
| 3213 | return false |
| 3214 | } |
| 3215 | return subjectParts[len(subjectParts)-1] == reqID |
| 3216 | } |
| 3217 | |
| 3218 | // MessageBatch provides methods to retrieve messages consumed using [Subscribe.FetchBatch]. |
| 3219 | type MessageBatch interface { |