提交 92a9d0a9 作者: Michael Avila

Add Close() to reprovider

License: MIT
Signed-off-by: 's avatarMichael Avila <davidmichaelavila@gmail.com>
上级 46296c4e
...@@ -45,6 +45,11 @@ func (rp *Reprovider) Run() { ...@@ -45,6 +45,11 @@ func (rp *Reprovider) Run() {
go rp.handleAnnouncements() go rp.handleAnnouncements()
} }
// Close stops thhe reprovider
func (rp *Reprovider) Close() error {
return rp.queue.Close()
}
// Trigger causes a reprovide // Trigger causes a reprovide
func (rp *Reprovider) Trigger(ctx context.Context) error { func (rp *Reprovider) Trigger(ctx context.Context) error {
select { select {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论