updated InputStreamThread.java and OutputStreamThread.java

Author: Daschi1

src/de/javasocketapi/core/Client.java

@@ -43,9 +43,9 @@ public void connect() throws IOException {
         }
         //start reading and writing
         this.inputStreamThread = new InputStreamThread(this);
-        this.inputStreamThread.start();
+        this.inputStreamThread.run();
         this.outputStreamThread = new OutputStreamThread(this);
-        this.outputStreamThread.start();
+        this.outputStreamThread.run();
     }
 
     @Override

src/de/javasocketapi/core/InputStreamThread.java

@@ -8,7 +8,7 @@
 import java.util.TimerTask;
 import java.util.UUID;
 
-class InputStreamThread extends Thread {
+class InputStreamThread {
 
     private Client client;
     private Socket socket;
@@ -23,9 +23,7 @@ public InputStreamThread(final Client client) {
         this.socket = this.client.getSocket();
     }
 
-    @Override
     public void run() {
-        super.run();
         //initialise inputStream
         InputStream inputStream = null;
         try {
@@ -84,9 +82,7 @@ public void run() {
         }, 0, 1);
     }
 
-    @Override
     public void interrupt() {
-        super.interrupt();
         this.timer.cancel();
     }
 }

src/de/javasocketapi/core/OutputStreamThread.java

@@ -9,7 +9,7 @@
 import java.util.Timer;
 import java.util.TimerTask;
 
-class OutputStreamThread extends Thread {
+class OutputStreamThread {
 
     private Client client;
     private Socket socket;
@@ -26,9 +26,7 @@ public OutputStreamThread(final Client client) {
         this.socket = this.client.getSocket();
     }
 
-    @Override
     public void run() {
-        super.run();
         //initialise outputStream
         OutputStream outputStream = null;
         try {
@@ -95,9 +93,7 @@ public void run() {
         }, 0, 1);
     }
 
-    @Override
     public void interrupt() {
-        super.interrupt();
         this.timer.cancel();
     }