Code formatted

Author: shreyasgosavi

exercises/practice/paasio/.meta/src/reference/java/Paasio.java

@@ -1,99 +1,137 @@
 import java.io.*;
 
-class FileOperations implements Closeable {
-
-    private FileInputStream fileInputStream;
-    private FileOutputStream fileOutputStream;
+public class Paasio implements Closeable {
 
     private long bytesRead;
-    private long bytesWritten;
     private long readOperationCount;
+    private long bytesWritten;
     private long writeOperationCount;
-    private String mode;
 
-    public FileOperations(File file, boolean readOperation){
+    private final InputStream inputStream;
+    private final OutputStream outputStream;
 
+    public Paasio(InputStream inputStream, OutputStream outputStream) throws FileNotFoundException {
+        this.inputStream = inputStream;
+        this.outputStream = outputStream;
     }
 
     public int read() throws IOException {
-
-        if (this.mode.equals("r")) {
-
-            int byteData = fileInputStream.read();
-            if (byteData != -1) {
-                bytesRead += byteData;
-                readOperationCount += 1;
-            }
-            return byteData;
-        } else {
-            throw new UnsupportedOperationException("Not in read mode.");
+        int byteData = inputStream.read();
+        if (byteData != -1) {
+            bytesRead += 1;
+            readOperationCount++;
         }
+        return byteData;
     }
 
     public int read(byte[] b) throws IOException {
 
-        return -1;
+        int totalBytesRead = inputStream.read(b);
+        if (totalBytesRead != -1) {
+            bytesRead += totalBytesRead;
+            readOperationCount++;
+        }
+        return totalBytesRead;
+
     }
 
     public int read(byte[] b, int off, int len) throws IOException {
-        return -1;
+
+        int bytesReadIntoBuffer = inputStream.read(b, off, len);
+
+        if (bytesReadIntoBuffer != -1) {
+            bytesRead += bytesReadIntoBuffer;
+            readOperationCount++;
+        }
+        return bytesReadIntoBuffer;
+
+
     }
 
     public byte[] readAllBytes() throws IOException {
-        return new byte[0];
+
+        byte[] allData = this.inputStream.readAllBytes();
+
+        if (allData.length > 0) {
+            readOperationCount++;
+            bytesRead += allData.length;
+        }
+        return allData;
+
     }
 
     public byte[] readNBytes(int len) throws IOException {
-        return new byte[0];
+//        return new byte[0];
+
+        byte[] allData = this.inputStream.readNBytes(len);
+        if (allData.length > 0) {
+            readOperationCount++;
+            bytesRead += allData.length;
+        }
+        return allData;
     }
 
-    @Override
-    public void close() throws IOException {
+    public void write(int b) throws IOException {
+
+        try {
+            this.outputStream.write(b);
+            writeOperationCount++;
+            bytesWritten++;
+
+        } catch (IOException ioException) {
+            ioException.printStackTrace();
+        }
 
     }
 
+    public void write(byte[] b) throws IOException {
+        try {
 
-    //Getter Setter
+            this.outputStream.write(b);
+            writeOperationCount++;
+            bytesWritten += b.length;
 
-    public long getBytesRead() {
-        return bytesRead;
-    }
 
-    public void setBytesRead(long bytesRead) {
-        this.bytesRead = bytesRead;
+        } catch (IOException ioException) {
+            ioException.printStackTrace();
+        }
     }
 
-    public long getBytesWritten() {
-        return bytesWritten;
+    public void write(byte[] b, int off, int len) throws IOException {
+        try {
+            this.outputStream.write(b, off, len);
+            writeOperationCount++;
+            bytesWritten += len;
+
+        } catch (IOException ioException) {
+            ioException.printStackTrace();
+        }
     }
 
-    public void setBytesWritten(long bytesWritten) {
-        this.bytesWritten = bytesWritten;
+    public long getBytesRead() {
+        return bytesRead;
     }
 
     public long getReadOperationCount() {
         return readOperationCount;
     }
 
-    public void setReadOperationCount(long readOperationCount) {
-        this.readOperationCount = readOperationCount;
+    public long getBytesWritten() {
+        return bytesWritten;
     }
 
     public long getWriteOperationCount() {
         return writeOperationCount;
     }
 
-    public void setWriteOperationCount(long writeOperationCount) {
-        this.writeOperationCount = writeOperationCount;
-    }
-
-    public String getMode() {
-        return mode;
+    @Override
+    public void close() throws IOException {
+        if (this.inputStream != null) {
+            this.inputStream.close();
+        }
+        if (this.outputStream != null) {
+            this.outputStream.close();
+        }
     }
 
-    public void setMode(String mode) {
-        this.mode = mode;
-    }
 }
-
-

exercises/practice/paasio/src/main/java/Paasio.java

@@ -1,6 +1,4 @@
 import java.io.*;
-import java.net.Socket;
-import java.util.Objects;
 
 public class Paasio implements Closeable {
 
@@ -113,12 +111,15 @@ public void write(byte[] b, int off, int len) throws IOException {
     public long getBytesRead() {
         return bytesRead;
     }
+
     public long getReadOperationCount() {
-        return readOperationCount;}
+        return readOperationCount;
+    }
 
     public long getBytesWritten() {
         return bytesWritten;
     }
+
     public long getWriteOperationCount() {
         return writeOperationCount;
     }