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