//
// Télé discussion sur Internet - Processus Ecouteur
//
// <http://cui.unige.ch/java/exemples>
//


import java.io.*;
import java.net.*;
import java.awt.*;

class Ecouteur extends Thread
{
  BufferedReader entree;
  TextArea  visu;

  public Ecouteur(Socket s,TextArea  out) throws IOException
  {
    entree= new BufferedReader (new InputStreamReader(s.getInputStream()));
    visu=out;
     this.start();
  }  // Ecouteur

  public void run()
  {
    String ligne;
    try {
      while (true) {
        ligne=entree.readLine();
        if (ligne==null) break;
        visu.append("\n"+ligne);
      }
    } catch (IOException e) { 
      visu.setText(e.toString());
    } finally {
      visu.setText("connexion interrompue par le serveur");
    }
  }  // run

} // class Ecouteur