We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 52154e9 commit 0df1e9cCopy full SHA for 0df1e9c
core/commands/p2p.go
@@ -310,7 +310,7 @@ var p2pLsCmd = &cmds.Command{
310
}
311
n.P2P.ListenersP2P.Unlock()
312
313
- return res.Emit(output)
+ return cmds.EmitOnce(res, output)
314
},
315
Type: P2PLsOutput{},
316
Encoders: cmds.EncoderMap{
@@ -398,7 +398,7 @@ var p2pCloseCmd = &cmds.Command{
398
done := n.P2P.ListenersLocal.Close(match)
399
done += n.P2P.ListenersP2P.Close(match)
400
401
- return res.Emit(done)
+ return cmds.EmitOnce(res, done)
402
403
Type: int(0),
404
@@ -454,7 +454,7 @@ var p2pStreamLsCmd = &cmds.Command{
454
455
n.P2P.Streams.Unlock()
456
457
458
459
Type: P2PStreamsOutput{},
460
0 commit comments