From: qydysky <qydysky@foxmail.com>
Date: Tue, 9 May 2023 17:40:15 +0000 (+0800)
Subject: fix
X-Git-Tag: v0.26.2
X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=2c8cedf07fb66a02692a0c7159b04fd0e2c83ada;p=part%2F.git

fix
---

diff --git a/msgq/Msgq.go b/msgq/Msgq.go
index 11a9682..7e78987 100644
--- a/msgq/Msgq.go
+++ b/msgq/Msgq.go
@@ -136,7 +136,7 @@ func (m *Msgq) PushLock_tag(Tag string, Data any) {
 	})
 }
 
-func (m *Msgq) Pull_tag_chan(key string, size int, ctx context.Context) chan any {
+func (m *Msgq) Pull_tag_chan(key string, size int, ctx context.Context) <-chan any {
 	var ch = make(chan any, size)
 	m.Register(func(data any) bool {
 		if d, ok := data.(Msgq_tag_data); ok && d.Tag == key {
@@ -243,7 +243,7 @@ func (m *MsgType[T]) ClearAll() {
 	m.m.ClearAll()
 }
 
-func (m *MsgType[T]) Pull_tag_chan(key string, size int, ctx context.Context) chan T {
+func (m *MsgType[T]) Pull_tag_chan(key string, size int, ctx context.Context) <-chan T {
 	var ch = make(chan T, size)
 	m.m.Register(func(data any) bool {
 		if d, ok := data.(Msgq_tag_data); ok && d.Tag == key {