diff --git a/commands/channelmarshaler.go b/commands/channelmarshaler.go
index 826b32eabe30e33aa3b69cc556da5d56fb51e38a..02cc4545e03c52e9579e0997b3a6ab30f4d165d7 100644
--- a/commands/channelmarshaler.go
+++ b/commands/channelmarshaler.go
@@ -5,6 +5,7 @@ import "io"
 type ChannelMarshaler struct {
 	Channel   <-chan interface{}
 	Marshaler func(interface{}) (io.Reader, error)
+	Res       Response
 
 	reader io.Reader
 }
@@ -13,6 +14,10 @@ func (cr *ChannelMarshaler) Read(p []byte) (int, error) {
 	if cr.reader == nil {
 		val, more := <-cr.Channel
 		if !more {
+			//check error in response
+			if cr.Res.Error() != nil {
+				return 0, cr.Res.Error()
+			}
 			return 0, io.EOF
 		}
 
diff --git a/commands/response.go b/commands/response.go
index a40c048df281be2be18078d77c9e71e77a6e2b1d..80938ab4d93034e0511dc0fac62fa66170515dc0 100644
--- a/commands/response.go
+++ b/commands/response.go
@@ -57,6 +57,7 @@ var marshallers = map[EncodingType]Marshaler{
 			return &ChannelMarshaler{
 				Channel:   ch,
 				Marshaler: marshalJson,
+				Res:       res,
 			}, nil
 		}
 
diff --git a/core/commands/dht.go b/core/commands/dht.go
index 1f081ba91ee6e90f82c527b1d4b3e808b2f8199d..0157b62e17278a2ad8dd8e94612d666c773f8c6f 100644
--- a/core/commands/dht.go
+++ b/core/commands/dht.go
@@ -131,6 +131,7 @@ var queryDhtCmd = &cmds.Command{
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
@@ -249,6 +250,7 @@ FindProviders will return a list of peers who are able to provide the value requ
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
@@ -354,6 +356,7 @@ var findPeerDhtCmd = &cmds.Command{
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
@@ -461,6 +464,7 @@ GetValue will return the value stored in the dht at the given key.
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
@@ -571,6 +575,7 @@ PutValue will store the given key value pair in the dht.
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
diff --git a/core/commands/ping.go b/core/commands/ping.go
index 2b4ff2dbf47c340de6230c527d417c6f90692e10..c06aa8dc69f95249b32c2d6eb73e6ecb2ee78359 100644
--- a/core/commands/ping.go
+++ b/core/commands/ping.go
@@ -71,6 +71,7 @@ trip latency information.
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
diff --git a/core/commands/refs.go b/core/commands/refs.go
index 1a015e2d8636a344b876e1be55b8581f017eedc0..b172d323a8b820d743a57164aaf5e6d087151cd1 100644
--- a/core/commands/refs.go
+++ b/core/commands/refs.go
@@ -141,6 +141,7 @@ Note: list all refs recursively with -r.
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
diff --git a/core/commands/repo.go b/core/commands/repo.go
index 8ad0c72967152521555491a4aecf5eabda760dd4..d0e010848389a738387106c143ad50acf5053d55 100644
--- a/core/commands/repo.go
+++ b/core/commands/repo.go
@@ -90,6 +90,7 @@ order to reclaim hard disk space.
 			return &cmds.ChannelMarshaler{
 				Channel:   outChan,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},
diff --git a/core/commands/stat.go b/core/commands/stat.go
index 5e222fa0458ab5d680a7da8a928976427fc6b421..df4c459ecbe00a679962cde03b32364e798dd248 100644
--- a/core/commands/stat.go
+++ b/core/commands/stat.go
@@ -167,6 +167,7 @@ var statBwCmd = &cmds.Command{
 			return &cmds.ChannelMarshaler{
 				Channel:   outCh,
 				Marshaler: marshal,
+				Res:       res,
 			}, nil
 		},
 	},