Unverified Commit 3a98ef95 authored by Steven Allen's avatar Steven Allen Committed by GitHub

Merge pull request #23 from ipfs/fix/return-errors

fix: return errors from the provider
parents 184f9bd2 056b8b66
......@@ -64,8 +64,7 @@ func NewProvider(ctx context.Context, queue *q.Queue, contentRouting routing.Con
// Close stops the provider
func (p *Provider) Close() error {
p.queue.Close()
return nil
return p.queue.Close()
}
// Run workers to handle provide requests.
......@@ -75,8 +74,7 @@ func (p *Provider) Run() {
// Provide the given cid using specified strategy.
func (p *Provider) Provide(root cid.Cid) error {
p.queue.Enqueue(root)
return nil
return p.queue.Enqueue(root)
}
// Handle all outgoing cids by providing (announcing) them
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment