DarthAffe/OBD.NET
1
0
Fork 0
mirror of https://github.com/DarthAffe/OBD.NET.git synced 2025-12-12 16:58:30 +00:00
Code Issues Releases Wiki Activity

Improved SerialConnection async-implementations

Browse Source
This commit is contained in:
Darth Affe 2022-06-05 20:12:25 +02:00
parent 1f6c3eaedf
commit 0d7dc3756b
2 changed files with 13 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
OBD.NET/OBD.NET/Communication/SerialConnection.cs
View File

@ -59,30 +59,16 @@ public class SerialConnection : ISerialConnection
public void Dispose() => _serialPort.Dispose(); public void Dispose() => _serialPort.Dispose();
public Task ConnectAsync() public async Task ConnectAsync()
{ {
try await Task.Yield();
{ Connect();
Connect();
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
} }
public Task WriteAsync(byte[] data) public async Task WriteAsync(byte[] data)
{ {
try await Task.Yield();
{ Write(data);
Write(data);
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
} }
public void Write(byte[] data) => _serialPort.Write(data, 0, data.Length); public void Write(byte[] data) => _serialPort.Write(data, 0, data.Length);
@ -151,30 +137,16 @@ public class SerialConnection : ISerialConnection
public void Dispose() => _serialPort.Dispose(); public void Dispose() => _serialPort.Dispose();
public Task ConnectAsync() public async Task ConnectAsync()
{ {
try await Task.Yield();
{ Connect();
Connect();
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
} }
public Task WriteAsync(byte[] data) public async Task WriteAsync(byte[] data)
{ {
try await Task.Yield();
{ Write(data);
Write(data);
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
} }
public void Write(byte[] data) => _serialPort.Write(data, 0, data.Length); public void Write(byte[] data) => _serialPort.Write(data, 0, data.Length);

3
OBD.NET/OBD.NET/Exceptions/SerialException.cs
View File

@ -16,7 +16,6 @@ public class SerialException : Exception
public SerialException(string message, Exception innerException) public SerialException(string message, Exception innerException)
: base(message, innerException) : base(message, innerException)
{ } { }
#endregion #endregion
} }