@effect/platform-node-shared
Advanced tools
Comparing version
@@ -316,9 +316,9 @@ "use strict"; | ||
{ | ||
emit.fromEffect(Effect.match(stat(path), { | ||
onSuccess: _ => FileSystem.WatchEventCreate({ | ||
emit.fromEffect(Effect.matchEffect(stat(path), { | ||
onSuccess: _ => Effect.succeed(FileSystem.WatchEventCreate({ | ||
path | ||
}), | ||
onFailure: _ => FileSystem.WatchEventRemove({ | ||
})), | ||
onFailure: err => err._tag === "SystemError" && err.reason === "NotFound" ? Effect.succeed(FileSystem.WatchEventRemove({ | ||
path | ||
}) | ||
})) : Effect.fail(err) | ||
})); | ||
@@ -325,0 +325,0 @@ return; |
@@ -309,9 +309,9 @@ import { effectify } from "@effect/platform/Effectify"; | ||
{ | ||
emit.fromEffect(Effect.match(stat(path), { | ||
onSuccess: _ => FileSystem.WatchEventCreate({ | ||
emit.fromEffect(Effect.matchEffect(stat(path), { | ||
onSuccess: _ => Effect.succeed(FileSystem.WatchEventCreate({ | ||
path | ||
}), | ||
onFailure: _ => FileSystem.WatchEventRemove({ | ||
})), | ||
onFailure: err => err._tag === "SystemError" && err.reason === "NotFound" ? Effect.succeed(FileSystem.WatchEventRemove({ | ||
path | ||
}) | ||
})) : Effect.fail(err) | ||
})); | ||
@@ -318,0 +318,0 @@ return; |
{ | ||
"name": "@effect/platform-node-shared", | ||
"version": "0.41.0", | ||
"version": "0.42.0", | ||
"description": "Unified interfaces for common platform-specific services", | ||
@@ -19,6 +19,6 @@ "license": "MIT", | ||
"peerDependencies": { | ||
"@effect/platform": "^0.86.0", | ||
"@effect/rpc": "^0.63.0", | ||
"@effect/cluster": "^0.40.0", | ||
"@effect/sql": "^0.39.0", | ||
"@effect/cluster": "^0.41.0", | ||
"@effect/platform": "^0.87.0", | ||
"@effect/rpc": "^0.64.0", | ||
"@effect/sql": "^0.40.0", | ||
"effect": "^3.16.9" | ||
@@ -25,0 +25,0 @@ }, |
@@ -546,5 +546,8 @@ import { effectify } from "@effect/platform/Effectify" | ||
case "rename": { | ||
emit.fromEffect(Effect.match(stat(path), { | ||
onSuccess: (_) => FileSystem.WatchEventCreate({ path }), | ||
onFailure: (_) => FileSystem.WatchEventRemove({ path }) | ||
emit.fromEffect(Effect.matchEffect(stat(path), { | ||
onSuccess: (_) => Effect.succeed(FileSystem.WatchEventCreate({ path })), | ||
onFailure: (err) => | ||
err._tag === "SystemError" && err.reason === "NotFound" | ||
? Effect.succeed(FileSystem.WatchEventRemove({ path })) | ||
: Effect.fail(err) | ||
})) | ||
@@ -551,0 +554,0 @@ return |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
443618
0.18%6427
0.05%