WingMan – Diff between revs 34 and 35

Subversion Repositories:
Rev:
Show entire file – Ignore whitespace
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 {