Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
bsideup committed Feb 21, 2017
1 parent b4925cf commit 8de4aea
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -100,14 +100,14 @@ InetSocketAddress start() throws IOException {
) {
log.info("Created RandomAccessFile from " + file);

Future<Long> inputFuture = executorService.submit(() -> {
Future inputFuture = executorService.submit(() -> {
log.info("Redirecting input");
return ByteStreams.copy(socketIn, fileOut);
return IOUtils.copy(socketIn, fileOut);
});

Future<Long> outputFuture = executorService.submit(() -> {
Future outputFuture = executorService.submit(() -> {
log.info("Redirecting output");
return ByteStreams.copy(fileIn, socketOut);
return IOUtils.copy(fileIn, socketOut);
});

inputFuture.get();
Expand Down

0 comments on commit 8de4aea

Please sign in to comment.