This commit is contained in:
cdle
2021-09-17 19:40:22 +08:00
parent 3c93a2b349
commit df5831a2e4
+4
View File
@@ -161,6 +161,7 @@ func (sender *Sender) Reply(msgs ...interface{}) error {
if rt != nil && sender.Duration != nil {
go func() {
time.Sleep(*sender.Duration)
sender.Delete()
b.Delete(rt)
}()
}
@@ -168,6 +169,9 @@ func (sender *Sender) Reply(msgs ...interface{}) error {
}
func (sender *Sender) Delete() error {
if sender.deleted {
return nil
}
msg := *sender.Message
sender.deleted = true
return b.Delete(&msg)