SerialPortStreamAdapter.cs

이 파일의 문서화 페이지로 가기

using System;
using System.IO;
using System.IO.Ports;
using System.Threading;
using System.Threading.Tasks;
 
namespace Dreamine.Communication.Serial.Streams;

public sealed class SerialPortStreamAdapter
{
    private readonly SerialPort _serialPort;

    public SerialPortStreamAdapter(SerialPort serialPort)
    {
        _serialPort = serialPort ?? throw new ArgumentNullException(nameof(serialPort));
    }

    public Stream BaseStream => _serialPort.BaseStream;

    public async Task WriteAsync(
        byte[] buffer,
        CancellationToken cancellationToken = default)
    {
        ArgumentNullException.ThrowIfNull(buffer);
        await BaseStream.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
        await BaseStream.FlushAsync(cancellationToken).ConfigureAwait(false);
    }

    public Task<int> ReadAsync(
        Memory<byte> buffer,
        CancellationToken cancellationToken = default)
    {
        return BaseStream.ReadAsync(buffer, cancellationToken).AsTask();
    }
}