Commit f8cd7a30 authored by David Stainton's avatar David Stainton

WIP

parent 0af6311c
......@@ -177,6 +177,9 @@ func (s *Session) SendUnreliableMessage(recipient, provider string, message []by
// WaitForReply blocks until a reply is received or the
// round trip timeout is reached.
func (s *Session) WaitForReply(id MessageID) ([]byte, error) {
s.awaitReplyMap
// XXX fix me
return nil, nil
}
......@@ -156,7 +156,10 @@ func (s *Session) eventSinkWorker() {
case *ConnectionStatusEvent:
// XXX fix me
case *MessageReplyEvent:
s.awaitReplyMap.Load(*e.MessageID)
_, ok := s.awaitReplyMap.Load(*e.MessageID)
if ok {
}
case *MessageSentEvent:
// XXX fix me
default:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment