Hush – Diff between revs 1 and 2

Subversion Repositories:

?pathlinks?

Rev 1 – Details – Blame – Last modification – View Log

 using System.Threading.Tasks;
 using Hush.Communication;
 using ProtoBuf;
 using WingMan.Communication;
-namespace Hush.Lobby
+namespace Hush.Chat
 {
-    public class LobbyMessageSynchronizer : IDisposable
+    public class ChatMessageSynchronizer : IDisposable
     {
-        public delegate void LobbyMessageReceived(object sender, LobbyMessageReceivedEventArgs e);
+        public delegate void MessageReceived(object sender, ChatMessageReceivedEventArgs e);
-        public LobbyMessageSynchronizer(MqttCommunication mqttCommunication, TaskScheduler taskScheduler,
+        public ChatMessageSynchronizer(string topic, MqttCommunication mqttCommunication, TaskScheduler taskScheduler,
+            CancellationToken cancellationToken)
             CancellationToken cancellationToken)
             Topic = topic;
             MqttCommunication = mqttCommunication;
             CancellationToken = cancellationToken;
             TaskScheduler = taskScheduler;
+            mqttCommunication.OnMessageReceived += MqttCommunicationOnOnMessageReceived;
+        }
             mqttCommunication.OnMessageReceived += MqttCommunicationOnOnMessageReceived;
         private string Topic { get; }
         private MqttCommunication MqttCommunication { get; }
         private CancellationToken CancellationToken { get; }
         private TaskScheduler TaskScheduler { get; }
         public void Dispose()
+        {
             MqttCommunication.OnMessageReceived -= MqttCommunicationOnOnMessageReceived;
+        }
-        public event LobbyMessageReceived OnLobbyMessageReceived;
+        public event MessageReceived OnMessageReceived;
         private async void MqttCommunicationOnOnMessageReceived(object sender,
             MqttCommunicationMessageReceivedEventArgs e)
+        {
-            if (e.Topic != "lobby")
+            if (e.Topic != Topic)
                 return;
             using (var memoryStream = new MemoryStream())
+            {
                 await e.PayloadStream.CopyToAsync(memoryStream);
                 memoryStream.Position = 0L;
-                var lobbyMessage = Serializer.Deserialize<LobbyMessage>(memoryStream);
+                var lobbyMessage = Serializer.Deserialize<ChatMessage>(memoryStream);
                 await Task.Delay(0, CancellationToken)
                     .ContinueWith(
-                        _ => OnLobbyMessageReceived?.Invoke(sender,
+                        _ => OnMessageReceived?.Invoke(sender,
-                            new LobbyMessageReceivedEventArgs(lobbyMessage.Nick, lobbyMessage.Message)),
+                            new ChatMessageReceivedEventArgs(lobbyMessage.Nick, lobbyMessage.Data)),
                         CancellationToken, TaskContinuationOptions.None, TaskScheduler);
+            }
+        }