We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9c7d3f8 commit dfcc14eCopy full SHA for dfcc14e
bufferflow_timedbinary.go
@@ -33,13 +33,13 @@ func (b *BufferflowTimedBinary) Init() {
33
for {
34
select {
35
case data := <-b.Input:
36
- bufferedOutputBinary = append(bufferedOutputBinary, []byte(data)...)
+ bufferedOutputBinary = append(bufferedOutputBinary, data...)
37
sPortBinary = b.Port
38
case <-b.ticker.C:
39
if bufferedOutputBinary != nil {
40
m := SpPortMessageRaw{sPortBinary, bufferedOutputBinary}
41
buf, _ := json.Marshal(m)
42
- b.Output <- []byte(buf)
+ b.Output <- buf
43
bufferedOutputBinary = nil
44
sPortBinary = ""
45
}
0 commit comments