routing: return errors of GetValuesAsync

ipfs · Mar 7, 2017 · 18e8c41 · 18e8c41 · GitCop · Mar 7, 2017
1 parent b297a2d
commit 18e8c41
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/routing/mock/centralized_client.go b/routing/mock/centralized_client.go
@@ -82,6 +82,7 @@ func (c *client) GetValuesAsync(ctx context.Context, key string, count int) <-ch
 	data, err := c.GetValue(ctx, key)
 	if err != nil {
 		log.Debugf("GetValuesAsync error: %v", err)
+		res <- &routing.RecvdVal{Error: err}
 	} else {
 		res <- &routing.RecvdVal{
 			Val:  data,

diff --git a/routing/offline/offline.go b/routing/offline/offline.go
@@ -97,6 +97,7 @@ func (c *offlineRouting) GetValuesAsync(ctx context.Context, key string, _ int)
 	value, err := c.GetValue(ctx, key)
 	if err != nil {
 		log.Debugf("OfflineRouting.GetValuesAsync: %v", err)
+		res <- &routing.RecvdVal{Error: err}
 	} else {
 		res <- &routing.RecvdVal{
 			Val: value,