WingMan – Diff between revs 5 and 7

Subversion Repositories:

?pathlinks?

Rev 5 – Rev 9 – Go to most recent revision – Details – Blame – Last modification – View Log

 ï»¿using System;
-using System.Collections.Generic;
 using System.IO;
-using System.Linq;
-using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 using MQTTnet;
 using WingMan.Communication;
-namespace WingMan
+namespace WingMan.Lobby
+{
     public class LobbyMessageSynchronizer : IDisposable
+    {
-        public delegate void LobbyMessageReceived(object sender, LobbyMessageReceivedEventArgs e);
+        public delegate void LobbyMessageReceived(object sender, LobbyMessageReceivedEventArgs e);
-        public event LobbyMessageReceived OnLobbyMessageReceived;
-        private MQTTCommunication MQTTCommunication { get; set; }
+        public LobbyMessageSynchronizer(MQTTCommunication MQTTCommunication, TaskScheduler taskScheduler,
-        public LobbyMessageSynchronizer(MQTTCommunication MQTTCommunication)
+            CancellationToken cancellationToken)
+        {
+            this.MQTTCommunication = MQTTCommunication;
             CancellationToken = cancellationToken;
-            this.MQTTCommunication = MQTTCommunication;
+            TaskScheduler = taskScheduler;
+            MQTTCommunication.OnMessageReceived += MqttCommunicationOnOnMessageReceived;
+        }
+        private MQTTCommunication MQTTCommunication { get; }
-            MQTTCommunication.OnMessageReceived += MqttCommunicationOnOnMessageReceived;
+        private CancellationToken CancellationToken { get; }
+        private TaskScheduler TaskScheduler { get; }
+        public void Dispose()
+        {
+            MQTTCommunication.OnMessageReceived -= MqttCommunicationOnOnMessageReceived;
+        }
+        public event LobbyMessageReceived OnLobbyMessageReceived;
-        }
         private async void MqttCommunicationOnOnMessageReceived(object sender,
-        private void MqttCommunicationOnOnMessageReceived(object sender, MqttApplicationMessageReceivedEventArgs e)
+            MqttApplicationMessageReceivedEventArgs e)
+        {
-            if(e.ApplicationMessage.Topic != "lobby")
+            if (e.ApplicationMessage.Topic != "lobby")
+                return;
+            using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload))
-                return;
+            {
+                var lobbyMessage = (LobbyMessage) LobbyMessage.XmlSerializer.Deserialize(memoryStream);
-            using (var memoryStream = new MemoryStream(e.ApplicationMessage.Payload))
+                await Task.Delay(0)
                     .ContinueWith(
-                var lobbyMessage = (LobbyMessage)LobbyMessage.XmlSerializer.Deserialize(memoryStream);
+                        _ => OnLobbyMessageReceived?.Invoke(sender,
                 memoryStream.Position = 0L;
                 await MQTTCommunication.Broadcast("lobby", memoryStream.ToArray()).ConfigureAwait(false);
+            }
-        }
-        public void Dispose()
-        {
-            MQTTCommunication.OnMessageReceived -= MqttCommunicationOnOnMessageReceived;
+        }
+    }