fumiama/orbyte
1
0
Fork 0
mirror of https://github.com/fumiama/orbyte.git synced 2026-06-17 17:10:42 +08:00
Code Activity

fix(pbuf): add keepalive in deep func

Browse Source
This commit is contained in:
源文雨
2025-04-02 19:57:57 +09:00
parent 326f247ad7
commit c427a15a7e
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pbuf/bytes.go
View File

@@ -2,6 +2,7 @@ package pbuf
import ( import (
"bytes" "bytes"
"runtime"
"github.com/fumiama/orbyte" "github.com/fumiama/orbyte"
) )
@@ -29,6 +30,7 @@ func BufferItemToBytes[USRDAT any](
func (b UserBytes[USRDAT]) B(f func([]byte, *USRDAT)) { func (b UserBytes[USRDAT]) B(f func([]byte, *USRDAT)) {
b.buf.P(func(ub *UserBuffer[USRDAT]) { b.buf.P(func(ub *UserBuffer[USRDAT]) {
f(ub.Buffer.Bytes(), &ub.DAT) f(ub.Buffer.Bytes(), &ub.DAT)
runtime.KeepAlive(b.buf)
}) })
} }
@@ -92,6 +94,7 @@ func (b UserBytes[USRDAT]) Cap() (c int) {
func (b UserBytes[USRDAT]) V(f func([]byte)) { func (b UserBytes[USRDAT]) V(f func([]byte)) {
b.buf.P(func(buf *UserBuffer[USRDAT]) { b.buf.P(func(buf *UserBuffer[USRDAT]) {
f(buf.Bytes()[b.a:b.b]) f(buf.Bytes()[b.a:b.b])
runtime.KeepAlive(b.buf)
}) })
} }