Newer
Older
package com.example.schedulerapp;
import java.io.*;
import java.net.*;
public class ReceiveThread {
private BufferedReader reader;
private Socket socket;
public ReceiveThread(Socket socket) {
this.socket = socket;
try {
InputStream input = socket.getInputStream();
reader = new BufferedReader(new InputStreamReader(input));
} catch (IOException error) {
System.out.println("Error getting input stream: " + error.getMessage());
error.printStackTrace();
}
}
public void run() {
while(true) {
try {
String response = reader.readLine();
// Split response by delimiter '/' then find out what it means.
} catch (IOException error) {
System.out.println("Error reading from server: " + error.getMessage());
error.printStackTrace();
break;
}
}
}
}