WingMan – Diff between revs 7 and 9

Subversion Repositories:
Rev:
Show entire file – Ignore whitespace
Rev 7 Rev 9
Line 9... Line 9...
9 { 9 {
10 public class LobbyMessageSynchronizer : IDisposable 10 public class LobbyMessageSynchronizer : IDisposable
11 { 11 {
12 public delegate void LobbyMessageReceived(object sender, LobbyMessageReceivedEventArgs e); 12 public delegate void LobbyMessageReceived(object sender, LobbyMessageReceivedEventArgs e);
Line 13... Line 13...
13   13  
14 public LobbyMessageSynchronizer(MQTTCommunication MQTTCommunication, TaskScheduler taskScheduler, 14 public LobbyMessageSynchronizer(MqttCommunication mqttCommunication, TaskScheduler taskScheduler,
15 CancellationToken cancellationToken) 15 CancellationToken cancellationToken)
16 { 16 {
17 this.MQTTCommunication = MQTTCommunication; 17 MqttCommunication = mqttCommunication;
18 CancellationToken = cancellationToken; 18 CancellationToken = cancellationToken;
Line 19... Line 19...
19 TaskScheduler = taskScheduler; 19 TaskScheduler = taskScheduler;
20   20  
Line 21... Line 21...
21 MQTTCommunication.OnMessageReceived += MqttCommunicationOnOnMessageReceived; 21 mqttCommunication.OnMessageReceived += MqttCommunicationOnOnMessageReceived;
Line 22... Line 22...
22 } 22 }
23   23  
Line 24... Line 24...
24 private MQTTCommunication MQTTCommunication { get; } 24 private MqttCommunication MqttCommunication { get; }
25   25  
26 private CancellationToken CancellationToken { get; } 26 private CancellationToken CancellationToken { get; }
27 private TaskScheduler TaskScheduler { get; } 27 private TaskScheduler TaskScheduler { get; }
Line 28... Line 28...
28   28  
Line 29... Line 29...
29 public void Dispose() 29 public void Dispose()
Line 55... Line 55...
55 { 55 {
56 using (var memoryStream = new MemoryStream()) 56 using (var memoryStream = new MemoryStream())
57 { 57 {
58 LobbyMessage.XmlSerializer.Serialize(memoryStream, new LobbyMessage 58 LobbyMessage.XmlSerializer.Serialize(memoryStream, new LobbyMessage
59 { 59 {
60 Nick = MQTTCommunication.Nick, 60 Nick = MqttCommunication.Nick,
61 Message = message 61 Message = message
62 }); 62 });
Line 63... Line 63...
63   63  
Line 64... Line 64...
64 memoryStream.Position = 0L; 64 memoryStream.Position = 0L;
65   65  
66 await MQTTCommunication.Broadcast("lobby", memoryStream.ToArray()).ConfigureAwait(false); 66 await MqttCommunication.Broadcast("lobby", memoryStream.ToArray()).ConfigureAwait(false);
67 } 67 }
68 } 68 }