This commit is contained in:
cdle
2021-10-11 17:31:10 +08:00
parent a578f4524d
commit 888ce3074d
+1
View File
@@ -245,6 +245,7 @@ func (sender *BaseSender) Await(callback func(string, error) interface{}, params
c.Result = make(chan interface{}, 1)
key := fmt.Sprintf("u=%v&c=%v&i=%v", sender.GetUserID(), sender.GetChatID(), sender.GetImType())
if oc, ok := waits.LoadOrStore(key, c); ok {
fmt.Println(waits.LoadOrStore(key, c))
oc.(Carry).Chan <- InterruptError
}
fmt.Println(waits.LoadOrStore(key, c))