如何将WatchService更改为stream api

Path directory = Paths.get("path/to/directory");
WatchService watchService = FileSystems.getDefault().newWatchService();
directory.register(watchService, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_MODIFY, StandardWatchEventKinds.ENTRY_DELETE);

while (true) {
    WatchKey key;
    try {
        key = watchService.take();
    } catch (InterruptedException e) {
        e.printStackTrace();
        return;
    }
    
    for (WatchEvent<?> event : key.pollEvents()) {
        WatchEvent.Kind<?> kind = event.kind();
        
        // 使用stream api处理事件
        if (kind == StandardWatchEventKinds.ENTRY_CREATE) {
            // 处理文件创建事件
        } else if (kind == StandardWatchEventKinds.ENTRY_MODIFY) {
            // 处理文件修改事件
        } else if (kind == StandardWatchEventKinds.ENTRY_DELETE) {
            // 处理文件删除事件
        }
    }
    
    boolean valid = key.reset();
    if (!valid) {
        break;
    }
}