[LIB-9] Replace engine sending commands via transmitter

[chesshog.git] / src / main / java / org / hedgecode / chess / uci / ConsoleAcceptorRunner.java

diff --git a/src/main/java/org/hedgecode/chess/uci/ConsoleAcceptorRunner.java b/src/main/java/org/hedgecode/chess/uci/ConsoleAcceptorRunner.java
index d699eed..e5a448f 100644 (file)
--- a/src/main/java/org/hedgecode/chess/uci/ConsoleAcceptorRunner.java
+++ b/src/main/java/org/hedgecode/chess/uci/ConsoleAcceptorRunner.java
@@ -61,11 +61,11 @@ public class ConsoleAcceptorRunner implements AcceptorRunner {
         Thread engineThread = new Thread(
                 new Runnable() {
                     public void run() {
-                        Receiver<String> acceptorReceiver = acceptor.receiver();
+                        Transmitter<String> acceptorTransmitter = acceptor.transmitter();
                         try {
-                            while (acceptorReceiver.isActive()) {
-                                if (acceptorReceiver.hasCommand()) {
-                                    String command = acceptorReceiver.receiveCommand();
+                            while (acceptorTransmitter.isActive()) {
+                                if (acceptorTransmitter.hasCommand()) {
+                                    String command = acceptorTransmitter.transmitCommand();
                                     if (command.isEmpty()) continue;
                                     CommandParams commandParams = new CommandParams(command);
                                     commandExecutor.exec(
@@ -74,11 +74,11 @@ public class ConsoleAcceptorRunner implements AcceptorRunner {
                                             commandParams.getParams()
                                     );
                                     if (UCIConstants.QUIT.equals(commandParams.getName()))
-                                        acceptorReceiver.stop();
+                                        acceptorTransmitter.stop();
                                 }
                             }
                         } finally {
-                            acceptorReceiver.close();
+                            acceptorTransmitter.close();
                             isRunning = false;
                         }
                     }