Add Close() to reprovider

License: MIT Signed-off-by: Michael Avila <davidmichaelavila@gmail.com>
ipfs · Apr 11, 2019 · 92a9d0a · 92a9d0a
1 parent 46296c4
commit 92a9d0a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/provider/reprovider.go b/provider/reprovider.go
@@ -45,6 +45,11 @@ func (rp *Reprovider) Run() {
 	go rp.handleAnnouncements()
 }
 
+// Close stops thhe reprovider
+func (rp *Reprovider) Close() error  {
+	return rp.queue.Close()
+}
+
 // Trigger causes a reprovide
 func (rp *Reprovider) Trigger(ctx context.Context) error {
 	select {