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

Implemented fake async-methods on SerialConnection

Browse Source
This commit is contained in:
Darth Affe 2022-06-05 20:06:16 +02:00
parent 2136aaf0ca
commit 1f6c3eaedf
1 changed files with 50 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -23,7 +23,7 @@ public class SerialConnection : ISerialConnection
#region Events
public event EventHandler<DataReceivedEventArgs>? DataReceived = delegate { };
public event EventHandler<DataReceivedEventArgs>? DataReceived = delegate { };
#endregion
@ -59,9 +59,31 @@ public class SerialConnection : ISerialConnection
public void Dispose() => _serialPort.Dispose();
public Task ConnectAsync() => throw new NotSupportedException("Asynchronous operations not supported");
public Task ConnectAsync()
{
try
{
Connect();
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
}
public Task WriteAsync(byte[] data) => throw new NotSupportedException("Asynchronous operations not supported");
public Task WriteAsync(byte[] data)
{
try
{
Write(data);
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
}
public void Write(byte[] data) => _serialPort.Write(data, 0, data.Length);
@ -129,9 +151,31 @@ public class SerialConnection : ISerialConnection
public void Dispose() => _serialPort.Dispose();
public Task ConnectAsync() => throw new NotSupportedException("Asynchronous operations not supported");
public Task ConnectAsync()
{
try
{
Connect();
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
}
public Task WriteAsync(byte[] data) => throw new NotSupportedException("Asynchronous operations not supported");
public Task WriteAsync(byte[] data)
{
try
{
Write(data);
return Task.CompletedTask;
}
catch (Exception ex)
{
return Task.FromException(ex);
}
}
public void Write(byte[] data) => _serialPort.Write(data, 0, data.Length);