feat(common.socket): return decoder

allseas · Oct 1, 2024 · af95ac7 · af95ac7
1 parent ee4addf
commit af95ac7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/plugins/common/socket/datagram.go b/plugins/common/socket/datagram.go
@@ -64,7 +64,9 @@ func (l *packetListener) listenData(onData CallbackData, onError CallbackError)
 			d := make([]byte, n)
 			copy(d, buf[:n])
 			l.parsePool.Submit(func() {
-				body, err := l.decoders.Get().(internal.ContentDecoder).Decode(d)
+				decoder := l.decoders.Get().(internal.ContentDecoder)
+				defer l.decoders.Put(decoder)
+				body, err := decoder.Decode(d)
 				if err != nil && onError != nil {
 					onError(fmt.Errorf("unable to decode incoming packet: %w", err))
 				}