diff --git a/session/send.go b/session/send.go index 9fa1a411874994c5744de991fe535e1aee4319ca..73899b2d10f13a4a9e8fa766a6462082045e6ab6 100644 --- a/session/send.go +++ b/session/send.go @@ -201,8 +201,7 @@ func (s *Session) BlockingSendUnreliableMessage(recipient, provider string, mess return nil, err } // wait until sent so that we know the ReplyETA for the waiting below - sentMessageRaw := <-sentWaitChan - sentMessage := sentMessageRaw.(*Message) + sentMessage := <-sentWaitChan s.sentWaitChanMap.Delete(*msg.ID) // wait for reply or round trip timeout select {