commands/object: use cmds.EmitOnce in single value
License: MIT Signed-off-by: Overbool <overbool.xu@gmail.com>
Overbool committed
Oct 30, 2018 at 11:19 UTC
e1d1f68f087443d915b3fd51c655f911ca450b3a
3 files changed
+11
-11
core/commands/object/diff.go
+1
-1
@@ -94,7 +94,7 @@ Example:
94
}
95
}
96
97
- return res.Emit(&Changes{out})
97
+ return cmds.EmitOnce(res, &Changes{out})
98
},
99
Type: Changes{},
100
Encoders: cmds.EncoderMap{
core/commands/object/object.go
+5
-5
@@ -148,7 +148,7 @@ multihash.
148
Links: outLinks,
149
}
150
151
- return res.Emit(out)
151
+ return cmds.EmitOnce(res, out)
152
},
153
Encoders: cmds.EncoderMap{
154
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *Object) error {
@@ -252,7 +252,7 @@ Supported values are:
252
}
253
}
254
255
- return res.Emit(node)
255
+ return cmds.EmitOnce(res, node)
256
},
257
Type: Node{},
258
Encoders: cmds.EncoderMap{
@@ -318,7 +318,7 @@ var ObjectStatCmd = &cmds.Command{
318
CumulativeSize: ns.CumulativeSize,
319
}
320
321
- return res.Emit(oldStat)
321
+ return cmds.EmitOnce(res, oldStat)
322
},
323
Type: ipld.NodeStat{},
324
Encoders: cmds.EncoderMap{
@@ -419,7 +419,7 @@ And then run:
419
return err
420
}
421
422
- return res.Emit(&Object{Hash: p.Cid().String()})
422
+ return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
423
},
424
Encoders: cmds.EncoderMap{
425
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *Object) error {
@@ -474,7 +474,7 @@ Available templates:
474
return err
475
}
476
477
- return res.Emit(&Object{Hash: nd.Cid().String()})
477
+ return cmds.EmitOnce(res, &Object{Hash: nd.Cid().String()})
478
},
479
Encoders: cmds.EncoderMap{
480
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *Object) error {
core/commands/object/patch.go
+5
-5
@@ -49,7 +49,7 @@ the limit will not be respected by the network.
49
cmdkit.StringArg("root", true, false, "The hash of the node to modify."),
50
cmdkit.FileArg("data", true, false, "Data to append.").EnableStdin(),
51
},
52
- Run: func(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment) error {
52
+ Run: func(req *cmds.Request, res cmds.ResponseEmitter, env cmds.Environment) error {
53
api, err := cmdenv.GetApi(env)
54
if err != nil {
55
return err
@@ -70,7 +70,7 @@ the limit will not be respected by the network.
70
return err
71
}
72
73
- return cmds.EmitOnce(re, &Object{Hash: p.Cid().String()})
73
+ return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
74
},
75
Type: &Object{},
76
Encoders: cmds.EncoderMap{
@@ -117,7 +117,7 @@ Example:
117
return err
118
}
119
120
- return res.Emit(&Object{Hash: p.Cid().String()})
120
+ return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
121
},
122
Type: Object{},
123
Encoders: cmds.EncoderMap{
@@ -156,7 +156,7 @@ Remove a Merkle-link from the given object and return the hash of the result.
156
return err
157
}
158
159
- return res.Emit(&Object{Hash: p.Cid().String()})
159
+ return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
160
},
161
Type: Object{},
162
Encoders: cmds.EncoderMap{
@@ -220,7 +220,7 @@ to a file containing 'bar', and returns the hash of the new object.
220
return err
221
}
222
223
- return res.Emit(&Object{Hash: p.Cid().String()})
223
+ return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
224
},
225
Type: Object{},
226
Encoders: cmds.EncoderMap{