Method
For
consumer_group_test.go:381–394
· consumer_group_test.go::mockJoinGroupCapture.For
(reqBody versionedDecoder)
Source from the content-addressed store, hash-verified
| 379 | } |
| 380 | |
| 381 | func (m *mockJoinGroupCapture) For(reqBody versionedDecoder) encoderWithHeader { |
| 382 | req := reqBody.(*JoinGroupRequest) |
| 383 | m.mu.Lock() |
| 384 | m.reasons = append(m.reasons, req.Reason) |
| 385 | if len(m.reasons) >= m.want { |
| 386 | select { |
| 387 | case <-m.captured: |
| 388 | default: |
| 389 | close(m.captured) |
| 390 | } |
| 391 | } |
| 392 | m.mu.Unlock() |
| 393 | return m.inner.For(reqBody) |
| 394 | } |
| 395 | |
| 396 | // mockLeaveGroupCapture wraps a MockLeaveGroupResponse and records the Reason |
| 397 | // from each incoming LeaveGroupRequest member. |
Callers
nothing calls this directly
Tested by
no test coverage detected