(stream, consumer string)
| 3505 | } |
| 3506 | |
| 3507 | func (js *js) getConsumerInfo(stream, consumer string) (*ConsumerInfo, error) { |
| 3508 | ctx, cancel := context.WithTimeout(context.Background(), js.opts.wait) |
| 3509 | defer cancel() |
| 3510 | return js.getConsumerInfoContext(ctx, stream, consumer) |
| 3511 | } |
| 3512 | |
| 3513 | func (js *js) getConsumerInfoContext(ctx context.Context, stream, consumer string) (*ConsumerInfo, error) { |
| 3514 | ccInfoSubj := fmt.Sprintf(apiConsumerInfoT, stream, consumer) |
no test coverage detected