equal
deleted
inserted
replaced
345 long startNanos = pr.start(); |
345 long startNanos = pr.start(); |
346 directoryStream.startAsync(startNanos); |
346 directoryStream.startAsync(startNanos); |
347 } |
347 } |
348 |
348 |
349 @Override |
349 @Override |
350 public void awaitTermination(Duration timeout) { |
350 public void awaitTermination(Duration timeout) throws InterruptedException { |
351 directoryStream.awaitTermination(timeout); |
351 directoryStream.awaitTermination(timeout); |
352 } |
352 } |
353 |
353 |
354 @Override |
354 @Override |
355 public void awaitTermination() { |
355 public void awaitTermination() throws InterruptedException { |
356 directoryStream.awaitTermination(); |
356 directoryStream.awaitTermination(); |
357 } |
357 } |
358 } |
358 } |