Function watchNative

packages/platform/deno/src/DenoFileSystem.ts:393–425

(
  path: string,
  options?: FileSystem.WatchOptions
)

  tryPromise("utimes", path, () => Deno.utime(path, atime, mtime))

const watchNative = (
  path: string,
  options?: FileSystem.WatchOptions
): Stream.Stream<FileSystem.WatchEvent, PlatformError.PlatformError> =>
  Stream.unwrap(
    Effect.map(
      Effect.try({
        try: () => Deno.watchFs(path, { recursive: options?.recursive ?? false }),
        catch: handleError("FileSystem", "watch", path)
      }),
      (watcher) =>
        Stream.fromAsyncIterable(watcher, handleError("FileSystem", "watch", path)).pipe(
          Stream.flatMap((event): Stream.Stream<FileSystem.WatchEvent, PlatformError.PlatformError> => {
            switch (event.kind) {
              case "create":
                return Stream.map(Stream.fromIterable(event.paths), (path) => ({ _tag: "Create" as const, path }))
              case "modify":
                return Stream.map(Stream.fromIterable(event.paths), (path) => ({ _tag: "Update" as const, path }))
              case "remove":
                return Stream.map(Stream.fromIterable(event.paths), (path) => ({ _tag: "Remove" as const, path }))
              case "rename":
                return Stream.mapEffect(Stream.fromIterable(event.paths), (path) =>
                  Effect.match(stat(path), {
                    onFailure: () => ({ _tag: "Remove" as const, path }),
                    onSuccess: () => ({ _tag: "Create" as const, path })
                  }))
              default:
                return Stream.empty
            }
          })
        )
    )
  )

const watch = (
  backend: Option.Option<FileSystem.WatchBackend["Service"]>,