update
This commit is contained in:
+1
-1
@@ -257,7 +257,7 @@ func (_ *BaseSender) Await(sender Sender, callback func(Sender, error) interface
|
|||||||
switch result.(type) {
|
switch result.(type) {
|
||||||
case Sender:
|
case Sender:
|
||||||
waits.Delete(key)
|
waits.Delete(key)
|
||||||
c.Result <- callback(c.Sender, nil)
|
c.Result <- callback(result.(Sender), nil)
|
||||||
return
|
return
|
||||||
case error:
|
case error:
|
||||||
waits.Delete(key)
|
waits.Delete(key)
|
||||||
|
|||||||
Reference in New Issue
Block a user