WingMan – Diff between revs 34 and 35
?pathlinks?
Rev 34 | Rev 35 | |||
---|---|---|---|---|
Line 28... | Line 28... | |||
28 | |
28 | |
|
Line 29... | Line 29... | |||
29 | public delegate void ClientSubscribed(object sender, MqttClientSubscribedTopicEventArgs e); |
29 | public delegate void ClientSubscribed(object sender, MqttClientSubscribedTopicEventArgs e); |
|
Line 30... | Line 30... | |||
30 | |
30 | |
|
Line 31... | Line 31... | |||
31 | public delegate void ClientUnsubscribed(object sender, MqttClientUnsubscribedTopicEventArgs e); |
31 | public delegate void ClientUnsubscribed(object sender, MqttClientUnsubscribedTopicEventArgs e); |
|
Line 32... | Line 32... | |||
32 | |
32 | |
|
Line 188... | Line 188... | |||
188 | { |
188 | { |
|
189 | using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
189 | using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
|
190 | { |
190 | { |
|
191 | using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
191 | using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
|
192 | { |
192 | { |
|
193 | using (var outpuStream = new MemoryStream()) |
193 | var outpuStream = new MemoryStream(); |
|
194 | { |
- | ||
195 | await lz4Decompress.CopyToAsync(outpuStream); |
194 | await lz4Decompress.CopyToAsync(outpuStream); |
|
Line 196... | Line 195... | |||
196 | |
195 | |
|
Line -... | Line 196... | |||
- | 196 | outpuStream.Position = 0L; |
||
197 | outpuStream.Position = 0L; |
197 | |
|
- | 198 | await Task.Delay(0, CancellationToken).ContinueWith( |
||
198 | |
199 | _ => OnMessageReceived?.Invoke(sender, |
|
- | 200 | new MqttCommunicationMessageReceivedEventArgs(e.ApplicationMessage.Topic, |
||
199 | e.ApplicationMessage.Payload = outpuStream.ToArray(); |
201 | outpuStream)), |
|
200 | } |
202 | CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
|
201 | } |
203 | } |
|
202 | } |
- | ||
203 | } |
- | ||
204 | |
- | ||
205 | await Task.Delay(0, CancellationToken).ContinueWith(_ => OnMessageReceived?.Invoke(sender, e), |
204 | } |
|
206 | CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
205 | } |
|
207 | } |
206 | } |
|
208 | catch (Exception ex) |
207 | catch (Exception ex) |
|
209 | { |
208 | { |
|
Line 290... | Line 289... | |||
290 | { |
289 | { |
|
291 | using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
290 | using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
|
292 | { |
291 | { |
|
293 | using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
292 | using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
|
294 | { |
293 | { |
|
295 | using (var outpuStream = new MemoryStream()) |
294 | var outpuStream = new MemoryStream(); |
|
296 | { |
- | ||
297 | await lz4Decompress.CopyToAsync(outpuStream); |
295 | await lz4Decompress.CopyToAsync(outpuStream); |
|
Line 298... | Line 296... | |||
298 | |
296 | |
|
Line -... | Line 297... | |||
- | 297 | outpuStream.Position = 0L; |
||
299 | outpuStream.Position = 0L; |
298 | |
|
- | 299 | await Task.Delay(0, CancellationToken).ContinueWith( |
||
300 | |
300 | _ => OnMessageReceived?.Invoke(sender, |
|
- | 301 | new MqttCommunicationMessageReceivedEventArgs(e.ApplicationMessage.Topic, |
||
301 | e.ApplicationMessage.Payload = outpuStream.ToArray(); |
302 | outpuStream)), |
|
302 | } |
303 | CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
|
303 | } |
304 | } |
|
304 | } |
- | ||
305 | } |
- | ||
306 | |
- | ||
307 | await Task.Delay(0, CancellationToken).ContinueWith(_ => OnMessageReceived?.Invoke(sender, e), |
305 | } |
|
308 | CancellationToken, TaskContinuationOptions.None, TaskScheduler); |
306 | } |
|
309 | } |
307 | } |
|
310 | catch (Exception ex) |
308 | catch (Exception ex) |
|
311 | { |
309 | { |