WingMan
| /trunk/WingMan/Lobby/LobbyMessageSynchronizer.cs |
|---|
| @@ -2,7 +2,6 @@ |
| using System.IO; |
| using System.Threading; |
| using System.Threading.Tasks; |
| using MQTTnet; |
| using WingMan.Communication; |
| namespace WingMan.Lobby |
| @@ -34,13 +33,17 @@ |
| public event LobbyMessageReceived OnLobbyMessageReceived; |
| private async void MqttCommunicationOnOnMessageReceived(object sender, |
| MqttApplicationMessageReceivedEventArgs e) |
| MqttCommunicationMessageReceivedEventArgs e) |
| { |
| if (e.ApplicationMessage.Topic != "lobby") |
| if (e.Topic != "lobby") |
| return; |
| using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload)) |
| using (var memoryStream = new MemoryStream()) |
| { |
| await e.PayloadStream.CopyToAsync(memoryStream); |
| memoryStream.Position = 0L; |
| var lobbyMessage = (LobbyMessage) LobbyMessage.XmlSerializer.Deserialize(memoryStream); |
| await Task.Delay(0) |
| @@ -67,4 +70,4 @@ |
| } |
| } |
| } |
| } |
| } |