commands: fix a bunch of tiny commands-lib issues

core/commands/dag/dag.go

@@ -188,7 +188,7 @@ format.
 			}
 			out = final
 		}
-		return res.Emit(&out)
+		return cmds.EmitOnce(res, &out)
 	},
 }
 
@@ -219,7 +219,7 @@ var DagResolveCmd = &cmds.Command{
 			return err
 		}
 
-		return res.Emit(&ResolveOutput{
+		return cmds.EmitOnce(res, &ResolveOutput{
 			Cid:     lastCid,
 			RemPath: path.Join(rem),
 		})

core/commands/dns.go

@@ -77,7 +77,7 @@ The resolver can recursively resolve:
 		if err != nil {
 			return err
 		}
-		return res.Emit(&ncmd.ResolvedPath{Path: output})
+		return cmds.EmitOnce(res, &ncmd.ResolvedPath{Path: output})
 	},
 	Encoders: cmds.EncoderMap{
 		cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *ncmd.ResolvedPath) error {

core/commands/pubsub.go

@@ -105,12 +105,14 @@ This command outputs data in the following encodings:
 				return err
 			}
 
-			res.Emit(&pubsubMessage{
+			if err := res.Emit(&pubsubMessage{
 				Data:     msg.Data(),
 				From:     []byte(msg.From()),
 				Seqno:    msg.Seq(),
 				TopicIDs: msg.Topics(),
-			})
+			}); err != nil {
+				return err
+			}
 		}
 	},
 	Encoders: cmds.EncoderMap{

core/commands/stat.go

@@ -127,22 +127,28 @@ Example:
 		for {
 			if pfound {
 				stats := nd.Reporter.GetBandwidthForPeer(pid)
-				res.Emit(&stats)
+				if err := res.Emit(&stats); err != nil {
+					return err
+				}
 			} else if tfound {
 				protoId := protocol.ID(tstr)
 				stats := nd.Reporter.GetBandwidthForProtocol(protoId)
-				res.Emit(&stats)
+				if err := res.Emit(&stats); err != nil {
+					return err
+				}
 			} else {
 				totals := nd.Reporter.GetBandwidthTotals()
-				res.Emit(&totals)
+				if err := res.Emit(&totals); err != nil {
+					return err
+				}
 			}
 			if !doPoll {
 				return nil
 			}
 			select {
 			case <-time.After(interval):
 			case <-req.Context.Done():
-				return nil
+				return req.Context.Err()
 			}
 		}
 	},

core/commands/tar.go

@@ -57,7 +57,7 @@ represent it.
 		c := node.Cid()
 
 		fi.FileName()
-		return res.Emit(&coreiface.AddEvent{
+		return cmds.EmitOnce(res, &coreiface.AddEvent{
 			Name: fi.FileName(),
 			Hash: c.String(),
 		})

core/commands/version.go

@@ -40,7 +40,7 @@ var VersionCmd = &cmds.Command{
 		cmdkit.BoolOption(versionAllOptionName, "Show all version information"),
 	},
 	Run: func(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment) error {
-		return res.Emit(&VersionOutput{
+		return cmds.EmitOnce(res, &VersionOutput{
 			Version: version.CurrentVersionNumber,
 			Commit:  version.CurrentCommit,
 			Repo:    fmt.Sprint(fsrepo.RepoVersion),