Skip to content
Snippets Groups Projects
ReceiveThread.java 982 B
Newer Older
  • Learn to ignore specific revisions
  • 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;
                }
    
            }
        }
    }