WingMan – Diff between revs 7 and 9
?pathlinks?
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 | } |