From 2c8cedf07fb66a02692a0c7159b04fd0e2c83ada Mon Sep 17 00:00:00 2001 From: qydysky Date: Wed, 10 May 2023 01:40:15 +0800 Subject: [PATCH] fix --- msgq/Msgq.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 { -- 2.39.2