Function
testConsumerGroupImmediateClose
(t *testing.T, ctx context.Context, r *Reader)
Source from the content-addressed store, hash-verified
| 654 | } |
| 655 | |
| 656 | func testConsumerGroupImmediateClose(t *testing.T, ctx context.Context, r *Reader) { |
| 657 | if err := r.Close(); err != nil { |
| 658 | t.Fatalf("bad err: %v", err) |
| 659 | } |
| 660 | } |
| 661 | |
| 662 | func testConsumerGroupSimple(t *testing.T, ctx context.Context, r *Reader) { |
| 663 | if err := r.Close(); err != nil { |
Callers
nothing calls this directly
Tested by
no test coverage detected