useSyncCommits indicates whether the Reader is configured to perform sync or async commits.
()
| 107 | // useSyncCommits indicates whether the Reader is configured to perform sync or |
| 108 | // async commits. |
| 109 | func (r *Reader) useSyncCommits() bool { return r.config.CommitInterval == 0 } |
| 110 | |
| 111 | func (r *Reader) unsubscribe() { |
| 112 | r.cancel() |
no outgoing calls
no test coverage detected