Testing file lock for create

DirectoryWatcherOnDiskTest.java

  @Test
  public void emitCreateEventWhenFileLocked() throws IOException, ExecutionException, InterruptedException {
    final CompletableFuture future = this.watcher.watchAsync();
    final Path child = Files.createTempFile(tmpDir, "child-", ".dat");
    FileChannel channel = null;
    FileLock lock = null;
    try {

      File file = child.toFile();
      channel = new RandomAccessFile(file, "rw").getChannel();
      lock = channel.lock();

      try {
        future.get(5, TimeUnit.SECONDS);
      } catch (TimeoutException e) {
        // Expected exception.
      }

      assertTrue(
          "Create event for the child file was notified",
          this.recorder.events.stream().anyMatch(
              e -> e.eventType() == DirectoryChangeEvent.EventType.CREATE && e.path().getFileName().equals(child.getFileName())));

    } finally {
      if(lock != null && channel != null && channel.isOpen()){
        lock.release();
        channel.close();
      }
    }
  }