WingMan – Diff between revs 32 and 35

Subversion Repositories:
Rev:
Show entire file – Ignore whitespace
Rev 32 Rev 35
Line 3... Line 3...
3 using System.Collections.Generic; 3 using System.Collections.Generic;
4 using System.IO; 4 using System.IO;
5 using System.Linq; 5 using System.Linq;
6 using System.Threading; 6 using System.Threading;
7 using System.Threading.Tasks; 7 using System.Threading.Tasks;
8 using MQTTnet; -  
9 using WingMan.Communication; 8 using WingMan.Communication;
Line 10... Line 9...
10   9  
11 namespace WingMan.Bindings 10 namespace WingMan.Bindings
12 { 11 {
Line 44... Line 43...
44 } 43 }
Line 45... Line 44...
45   44  
Line 46... Line 45...
46 public event MouseKeyBindingsSynchronized OnMouseKeyBindingsSynchronized; 45 public event MouseKeyBindingsSynchronized OnMouseKeyBindingsSynchronized;
47   46  
48 private async void MqttCommunicationOnMessageReceived(object sender, 47 private async void MqttCommunicationOnMessageReceived(object sender,
49 MqttApplicationMessageReceivedEventArgs e) 48 MqttCommunicationMessageReceivedEventArgs e)
50 { 49 {
Line 51... Line 50...
51 if (e.ApplicationMessage.Topic != "exchange") 50 if (e.Topic != "exchange")
52 return; 51 return;
-   52  
-   53 using (var memoryStream = new MemoryStream())
53   54 {
Line 54... Line 55...
54 using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload)) 55 await e.PayloadStream.CopyToAsync(memoryStream);
55 { 56  
Line 98... Line 99...
98 await MqttCommunication.Broadcast("exchange", memoryStream.ToArray()); 99 await MqttCommunication.Broadcast("exchange", memoryStream.ToArray());
99 } 100 }
100 } while (!CancellationToken.IsCancellationRequested); 101 } while (!CancellationToken.IsCancellationRequested);
101 } 102 }
102 } 103 }
103 } -  
104   104 }
-   105