diff --git a/src/laminar.cpp b/src/laminar.cpp
index 4909473..51847bb 100644
--- a/src/laminar.cpp
+++ b/src/laminar.cpp
@@ -518,7 +518,6 @@ void Laminar::reapAdvance() {
         std::shared_ptr<Run> run = *it;
         bool completed = true;
         activeJobs.get<0>().modify(it, [&](std::shared_ptr<Run> run){
-            close(run->fd);
             run->reaped(ret);
             completed = stepRun(run);
         });
diff --git a/src/server.cpp b/src/server.cpp
index 96d19d5..a4547af 100644
--- a/src/server.cpp
+++ b/src/server.cpp
@@ -389,7 +389,7 @@ void Server::stop() {
 }
 
 void Server::addDescriptor(int fd, std::function<void(char*,size_t)> cb) {
-    auto event = this->ioContext.lowLevelProvider->wrapInputFd(fd);
+    auto event = this->ioContext.lowLevelProvider->wrapInputFd(fd, kj::LowLevelAsyncIoProvider::TAKE_OWNERSHIP);
     tasks.add(handleFdRead(event, cb).attach(std::move(event)));
 }