| /trunk/WingMan/Communication/MqttCommunication.cs |
|---|
| @@ -30,7 +30,7 @@ |
|---|
| |
| public delegate void ClientUnsubscribed(object sender, MqttClientUnsubscribedTopicEventArgs e); |
| |
| public delegate void MessageReceived(object sender, MqttApplicationMessageReceivedEventArgs e); |
| public delegate void MessageReceived(object sender, MqttCommunicationMessageReceivedEventArgs e); |
| |
| public delegate void ServerAuthenticationFailed(object sender, MqttAuthenticationFailureEventArgs e); |
| |
| @@ -190,20 +190,19 @@ |
|---|
| { |
| using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
| { |
| using (var outpuStream = new MemoryStream()) |
| { |
| await lz4Decompress.CopyToAsync(outpuStream); |
| var outpuStream = new MemoryStream(); |
| await lz4Decompress.CopyToAsync(outpuStream); |
| |
| outpuStream.Position = 0L; |
| outpuStream.Position = 0L; |
| |
| e.ApplicationMessage.Payload = outpuStream.ToArray(); |
| } |
| await Task.Delay(0, CancellationToken).ContinueWith( |
| _ => OnMessageReceived?.Invoke(sender, |
| new MqttCommunicationMessageReceivedEventArgs(e.ApplicationMessage.Topic, |
| outpuStream)), |
| CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
| } |
| } |
| } |
| |
| await Task.Delay(0, CancellationToken).ContinueWith(_ => OnMessageReceived?.Invoke(sender, e), |
| CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
| } |
| catch (Exception ex) |
| { |
| @@ -292,20 +291,19 @@ |
|---|
| { |
| using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
| { |
| using (var outpuStream = new MemoryStream()) |
| { |
| await lz4Decompress.CopyToAsync(outpuStream); |
| var outpuStream = new MemoryStream(); |
| await lz4Decompress.CopyToAsync(outpuStream); |
| |
| outpuStream.Position = 0L; |
| outpuStream.Position = 0L; |
| |
| e.ApplicationMessage.Payload = outpuStream.ToArray(); |
| } |
| await Task.Delay(0, CancellationToken).ContinueWith( |
| _ => OnMessageReceived?.Invoke(sender, |
| new MqttCommunicationMessageReceivedEventArgs(e.ApplicationMessage.Topic, |
| outpuStream)), |
| CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
| } |
| } |
| } |
| |
| await Task.Delay(0, CancellationToken).ContinueWith(_ => OnMessageReceived?.Invoke(sender, e), |
| CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
| } |
| catch (Exception ex) |
| { |
