AbstractRS232Device.java

package devices;

import kernel.serial_ports.PortCommunicator;

import java.io.*;

abstract class AbstractRS232Device implements RS232Device {
    private final PortCommunicator portCommunicator;

    protected AbstractRS232Device(PortCommunicator portCommunicator){
        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();
    }
}