RS232Device.java

package devices;

import kernel.serial_ports.PortCommunicator;

import java.io.*;

abstract class RS232Device implements NamedDevice {
    private final PortCommunicator portCommunicator;
    protected final String deviceName;

    public RS232Device(String deviceName, PortCommunicator portCommunicator){
        this.deviceName = deviceName;
        this.portCommunicator = portCommunicator;
    }

    protected String read() throws IOException {
        InputStream inputStream = this.portCommunicator.getInputStream();
        InputStreamReader inputStreamReader = new InputStreamReader
                (inputStream);

        BufferedReader inputStreamBuffer = new BufferedReader
                (inputStreamReader);

        return inputStreamBuffer.readLine();
    }

    protected void write(String commandToWrite) throws IOException {
        OutputStream outputStream = this.portCommunicator.getOutputStream();
        OutputStreamWriter streamWriter = new OutputStreamWriter(outputStream);
        BufferedWriter buffer = new BufferedWriter(streamWriter);

        buffer.write(commandToWrite);
        buffer.flush();
    }
}