X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fxdcc%2Fui%2Fstdin%2FNetworkAdapter.java;h=bfbaee5d172d934aa4bd4d13429a26ace88f3b8a;hb=f76ee64d2cd93a0439c6306e1fcf6230c633590c;hp=a45a341d1f14867f268de3c41ab1e94650b8f2e1;hpb=ae91c1d80ef6b6e4cb9b8417301b4f057375b3b1;p=xudocci.git 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 --- 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() {