Add possibility to restart/research failed downloads.

[xudocci.git] / src / main / java / net / pterodactylus / xdcc / ui / stdin / NetworkAdapter.java

diff --git a/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java b/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java
index a45a341..bfbaee5 100644 (file)
--- a/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java
+++ b/src/main/java/net/pterodactylus/xdcc/ui/stdin/NetworkAdapter.java
@@ -42,19 +42,18 @@ public class NetworkAdapter extends AbstractExecutionThreadService {
        /** The event bus. */
        private final EventBus eventBus;
 
-       /** The core being controlled. */
-       private final Core core;
+       private final CommandReaderFactory commandReaderFactory;
        private final int port;
 
        /**
         * Creates a new network acceptor.
         *
         * @param eventBus
-        * @param core
+        * @param commandReaderFactory
         */
-       public NetworkAdapter(EventBus eventBus, Core core, int port) {
+       public NetworkAdapter(EventBus eventBus, CommandReaderFactory commandReaderFactory, int port) {
                this.eventBus = eventBus;
-               this.core = core;
+               this.commandReaderFactory = commandReaderFactory;
                this.port = port;
        }
 
@@ -69,7 +68,7 @@ public class NetworkAdapter extends AbstractExecutionThreadService {
                                OutputStream socketOutputStream = clientSocket.getOutputStream();
                                final InputStreamReader socketInputStreamReader = new InputStreamReader(socketInputStream, "UTF-8");
                                final OutputStreamWriter socketOutputStreamWriter = new OutputStreamWriter(socketOutputStream, "UTF-8");
-                               final CommandReader commandReader = new CommandReader(core, socketInputStreamReader, socketOutputStreamWriter);
+                               final CommandReader commandReader = commandReaderFactory.create(socketInputStreamReader, socketOutputStreamWriter);
                                eventBus.register(commandReader);
                                commandReader.addListener(new Listener() {