richtiger Chat

src/ChatProgramm/controller/commands/CommandSend.java

   public void execute()
   {
       if(transmitterInterface != null && !eingabeFeld.getText().isEmpty()){
-          transmitterInterface.send(new Nachricht("Du: " + eingabeFeld.getText()));
+          transmitterInterface.send(eingabeFeld.getText());
           eingabeFeld.setText("");
       }
   }

src/ChatProgramm/model/ReceiveAdapter.java

     @Override
     public void onNext(Nachricht item) {
 
-        view.getTxtChat().append("\n" + item.getNachricht());
+        view.getTxtChat().append(item.getNachricht());
         this.subscription.request(1);
     }
 

src/ChatProgramm/model/Transmitter.java

     protected PrintWriter writer;
     
     private Nachricht nachricht;
+    private String txtNachricht;
     private boolean laufend;
     private SubmissionPublisher<Nachricht> textPublisher;
     private ExecutorService eService;
       textPublisher = new SubmissionPublisher<>();
       this.view = view;
       addWertSubscription(receiveAdapter);
+      nachricht = new Nachricht("");
     }
     
      public void addWertSubscription(Subscriber<Nachricht> subscriber)
       }
     }
     
-    public void send(Nachricht nachricht){
-      
-        writer.println(nachricht.getNachricht());
+    public void send(String txtNachricht){
+
+        writer.println(txtNachricht);
         writer.flush();
         lg.info("Nachricht gesendet");
+        nachricht.setNachricht("\nDu: " + txtNachricht);
         textPublisher.submit(nachricht);
     }
     public Nachricht receive(){
-      Nachricht nachricht = new Nachricht("");
       try {
-        String txtNachricht = reader.readLine();
+        txtNachricht = reader.readLine();
         if(!txtNachricht.isEmpty()){
           lg.info("Nachricht erhalten");
-          nachricht.setNachricht("Er / Sie: " + txtNachricht);
+          nachricht.setNachricht("\nEr / Sie: " + txtNachricht);
           return nachricht;
         }
 
       while (true) {
         lg.info("Warte auf Nachricht");
         if(laufend) {
-          Nachricht eingehendeNachricht = receive();
-          if(!eingehendeNachricht.getNachricht().isEmpty()){
-              textPublisher.submit(eingehendeNachricht);
+          nachricht = receive();
+          if(!nachricht.getNachricht().isEmpty()){
+              textPublisher.submit(nachricht);
           }
         }
         else{

src/ChatProgramm/model/TransmitterInterface.java

  */
 public interface TransmitterInterface
 {
-    public void send(Nachricht nachricht);
+    public void send(String txtNachricht);
     public Nachricht receive();
 
 }