WingMan
| /trunk/WingMan/Communication/MqttCommunication.cs |
|---|
| @@ -63,7 +63,7 @@ |
| private IPAddress IpAddress { get; set; } |
| private int Port { get; set; } |
| public int Port { get; set; } |
| private string Password { get; set; } |
| @@ -159,9 +159,9 @@ |
| private async Task StopClient() |
| { |
| await Client.StopAsync(); |
| UnbindClientHandlers(); |
| await Client.StopAsync(); |
| } |
| public void BindClientHandlers() |
| @@ -186,7 +186,7 @@ |
| { |
| using (var inputStream = new MemoryStream(e.ApplicationMessage.Payload)) |
| { |
| using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
| using (var decryptedStream = await Aes.Decrypt(inputStream, Password)) |
| { |
| using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
| { |
| @@ -254,9 +254,9 @@ |
| private async Task StopServer() |
| { |
| await Server.StopAsync(); |
| UnbindServerHandlers(); |
| await Server.StopAsync(); |
| } |
| private void BindServerHandlers() |
| @@ -287,7 +287,7 @@ |
| { |
| using (var inputStream = new MemoryStream(e.ApplicationMessage.Payload)) |
| { |
| using (var decryptedStream = await AES.Decrypt(inputStream, Password)) |
| using (var decryptedStream = await Aes.Decrypt(inputStream, Password)) |
| { |
| using (var lz4Decompress = new LZ4Stream(decryptedStream, CompressionMode.Decompress)) |
| { |
| @@ -383,7 +383,7 @@ |
| compressStream.Position = 0L; |
| using (var outputStream = await AES.Encrypt(compressStream, Password)) |
| using (var outputStream = await Aes.Encrypt(compressStream, Password)) |
| { |
| var data = outputStream.ToArray(); |
| switch (Type) |