Skip to content
This repository was archived by the owner on Sep 29, 2024. It is now read-only.

Commit bd82ad3

Browse files
sshaplygingoogollee
authored andcommitted
fix: encoder
1 parent 7b3dd4b commit bd82ad3

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

parser/encoder.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,10 +107,11 @@ func (e *Encoder) writePacket(w io.WriteCloser, h Header, args []interface{}) ([
107107
}
108108

109109
if len(args) > 0 {
110-
if err := json.NewEncoder(bw).Encode(args); err != nil {
110+
if err := json.NewEncoder(bw).Encode(args[0]); err != nil {
111111
return nil, err
112112
}
113113
}
114+
114115
if f, ok := bw.(flusher); ok {
115116
if err := f.Flush(); err != nil {
116117
return nil, err
@@ -183,6 +184,7 @@ func (e *Encoder) attachBuffer(v reflect.Value, index *uint64) ([][]byte, error)
183184
ret = append(ret, b...)
184185
}
185186
}
187+
186188
return ret, nil
187189
}
188190

parser/packet_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ var tests = []struct {
3131
},
3232
[][]byte{
3333
[]byte("51-[\"msg\",{\"_placeholder\":true,\"num\":0}]\n"),
34-
[]byte{1, 2, 3},
34+
{1, 2, 3},
3535
},
3636
},
3737
{"ID",
@@ -60,7 +60,7 @@ var tests = []struct {
6060
},
6161
[][]byte{
6262
[]byte("61-13[{\"_placeholder\":true,\"num\":0}]\n"),
63-
[]byte{1, 2, 3},
63+
{1, 2, 3},
6464
},
6565
},
6666
{"Namespace",
@@ -89,7 +89,7 @@ var tests = []struct {
8989
},
9090
[][]byte{
9191
[]byte("51-/woot,[\"msg\",{\"_placeholder\":true,\"num\":0}]\n"),
92-
[]byte{2, 3, 4},
92+
{2, 3, 4},
9393
},
9494
},
9595
{"NamespaceID",
@@ -117,7 +117,7 @@ var tests = []struct {
117117
},
118118
[][]byte{
119119
[]byte("51-/woot,1[\"msg\",{\"_placeholder\":true,\"num\":0}]\n"),
120-
[]byte{2, 3, 4},
120+
{2, 3, 4},
121121
},
122122
},
123123
}

0 commit comments

Comments
 (0)