Fix `unreachable`

1 files changed, 6 insertions, 3 deletions

diff --git a/src/bun.js/webcore/streams.zig b/src/bun.js/webcore/streams.zig
index 2695a43e2..65a34f0ce 100644
--- a/src/bun.js/webcore/streams.zig
+++ b/src/bun.js/webcore/streams.zig
@@ -7,7 +7,7 @@ const ZigURL = @import("../../url.zig").URL;
 const HTTPClient = @import("http");
 const NetworkThread = HTTPClient.NetworkThread;
 const AsyncIO = NetworkThread.AsyncIO;
-const JSC = @import("root").JSC;
+const JSC = @import("javascript_core");
 const js = JSC.C;
 
 const Method = @import("../../http/method.zig").Method;
@@ -1118,9 +1118,12 @@ pub const FileSink = struct {
     }
 
     fn cleanup(this: *FileSink) void {
-        this.unwatch(this.fd);
-
         if (this.fd != std.math.maxInt(JSC.Node.FileDescriptor)) {
+            if (this.scheduled_count > 0) {
+                this.scheduled_count = 0;
+                this.unwatch(this.fd);
+            }
+
             _ = JSC.Node.Syscall.close(this.fd);
             this.fd = std.math.maxInt(JSC.Node.FileDescriptor);
         }