WingMan – Diff between revs 32 and 35

Subversion Repositories:
Rev:
Show entire file – Ignore whitespace
Rev 32 Rev 35
Line 1... Line 1...
1 using System; 1 using System;
2 using System.IO; 2 using System.IO;
3 using System.Threading; 3 using System.Threading;
4 using System.Threading.Tasks; 4 using System.Threading.Tasks;
5 using MQTTnet; -  
6 using WingMan.Communication; 5 using WingMan.Communication;
Line 7... Line 6...
7   6  
8 namespace WingMan.Lobby 7 namespace WingMan.Lobby
9 { 8 {
Line 32... Line 31...
32 } 31 }
Line 33... Line 32...
33   32  
Line 34... Line 33...
34 public event LobbyMessageReceived OnLobbyMessageReceived; 33 public event LobbyMessageReceived OnLobbyMessageReceived;
35   34  
36 private async void MqttCommunicationOnOnMessageReceived(object sender, 35 private async void MqttCommunicationOnOnMessageReceived(object sender,
37 MqttApplicationMessageReceivedEventArgs e) 36 MqttCommunicationMessageReceivedEventArgs e)
38 { 37 {
Line 39... Line 38...
39 if (e.ApplicationMessage.Topic != "lobby") 38 if (e.Topic != "lobby")
40 return; 39 return;
-   40  
-   41 using (var memoryStream = new MemoryStream())
-   42 {
-   43 await e.PayloadStream.CopyToAsync(memoryStream);
41   44  
Line 42... Line 45...
42 using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload)) 45 memoryStream.Position = 0L;
43 { 46  
44 var lobbyMessage = (LobbyMessage) LobbyMessage.XmlSerializer.Deserialize(memoryStream); 47 var lobbyMessage = (LobbyMessage) LobbyMessage.XmlSerializer.Deserialize(memoryStream);
Line 65... Line 68...
65   68  
66 await MqttCommunication.Broadcast("lobby", memoryStream.ToArray()); 69 await MqttCommunication.Broadcast("lobby", memoryStream.ToArray());
67 } 70 }
68 } 71 }
69 } -  
70 } 72 }
-   73 }