Skip to content

Commit e1d1f68

Browse files
overboolStebalien
authored andcommitted
commands/object: use cmds.EmitOnce in single value
License: MIT Signed-off-by: Overbool <[email protected]>
1 parent 0fe7bdf commit e1d1f68

File tree

3 files changed

+11
-11
lines changed

3 files changed

+11
-11
lines changed

core/commands/object/diff.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ Example:
9494
}
9595
}
9696

97-
return res.Emit(&Changes{out})
97+
return cmds.EmitOnce(res, &Changes{out})
9898
},
9999
Type: Changes{},
100100
Encoders: cmds.EncoderMap{

core/commands/object/object.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ multihash.
148148
Links: outLinks,
149149
}
150150

151-
return res.Emit(out)
151+
return cmds.EmitOnce(res, out)
152152
},
153153
Encoders: cmds.EncoderMap{
154154
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *Object) error {
@@ -252,7 +252,7 @@ Supported values are:
252252
}
253253
}
254254

255-
return res.Emit(node)
255+
return cmds.EmitOnce(res, node)
256256
},
257257
Type: Node{},
258258
Encoders: cmds.EncoderMap{
@@ -318,7 +318,7 @@ var ObjectStatCmd = &cmds.Command{
318318
CumulativeSize: ns.CumulativeSize,
319319
}
320320

321-
return res.Emit(oldStat)
321+
return cmds.EmitOnce(res, oldStat)
322322
},
323323
Type: ipld.NodeStat{},
324324
Encoders: cmds.EncoderMap{
@@ -419,7 +419,7 @@ And then run:
419419
return err
420420
}
421421

422-
return res.Emit(&Object{Hash: p.Cid().String()})
422+
return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
423423
},
424424
Encoders: cmds.EncoderMap{
425425
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *Object) error {
@@ -474,7 +474,7 @@ Available templates:
474474
return err
475475
}
476476

477-
return res.Emit(&Object{Hash: nd.Cid().String()})
477+
return cmds.EmitOnce(res, &Object{Hash: nd.Cid().String()})
478478
},
479479
Encoders: cmds.EncoderMap{
480480
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, out *Object) error {

core/commands/object/patch.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ the limit will not be respected by the network.
4949
cmdkit.StringArg("root", true, false, "The hash of the node to modify."),
5050
cmdkit.FileArg("data", true, false, "Data to append.").EnableStdin(),
5151
},
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 {
5353
api, err := cmdenv.GetApi(env)
5454
if err != nil {
5555
return err
@@ -70,7 +70,7 @@ the limit will not be respected by the network.
7070
return err
7171
}
7272

73-
return cmds.EmitOnce(re, &Object{Hash: p.Cid().String()})
73+
return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
7474
},
7575
Type: &Object{},
7676
Encoders: cmds.EncoderMap{
@@ -117,7 +117,7 @@ Example:
117117
return err
118118
}
119119

120-
return res.Emit(&Object{Hash: p.Cid().String()})
120+
return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
121121
},
122122
Type: Object{},
123123
Encoders: cmds.EncoderMap{
@@ -156,7 +156,7 @@ Remove a Merkle-link from the given object and return the hash of the result.
156156
return err
157157
}
158158

159-
return res.Emit(&Object{Hash: p.Cid().String()})
159+
return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
160160
},
161161
Type: Object{},
162162
Encoders: cmds.EncoderMap{
@@ -220,7 +220,7 @@ to a file containing 'bar', and returns the hash of the new object.
220220
return err
221221
}
222222

223-
return res.Emit(&Object{Hash: p.Cid().String()})
223+
return cmds.EmitOnce(res, &Object{Hash: p.Cid().String()})
224224
},
225225
Type: Object{},
226226
Encoders: cmds.EncoderMap{

0 commit comments

Comments
 (0)