diff --git a/bot/client.go b/bot/client.go index 0b23b62..4a70d36 100644 --- a/bot/client.go +++ b/bot/client.go @@ -64,6 +64,7 @@ func warpConn(c *net.Conn) *Conn { break } if ok := wc.recv.Push(p); !ok { + wc.rerr = errors.New("receive queue is full") break } }