diff --git a/proxy/server/target.go b/proxy/server/target.go
index 21c870ed..b3098de8 100644
--- a/proxy/server/target.go
+++ b/proxy/server/target.go
@@ -226,6 +226,7 @@ func (s *TargetStream) Run(nonce uint32, replyChan chan *pb.ProxyReply) {
 					return nil
 				}
 				if err != nil {
+					s.CloseWith(err)
 					return err
 				}
 				// otherwise, this is a streamData reply