2 files changed, 4 insertions, 5 deletions
diff --git a/src/detached/client.zig b/src/detached/client.zig
index 7cee790a..6476d521 100644
--- a/src/detached/client.zig
+++ b/src/detached/client.zig
@@ -884,7 +884,7 @@ test "detached selection pipe runs off the loop and returns through the attached
         while (try client.next()) |_| {}
         if (std.mem.eql(u8, pane.file.?.content, "ONE\ntwo\n")) break;
     } else return error.PipeDidNotComplete;
-    try testing.expect(h.core.pipe_wait == null);
+    try testing.expect(h.core.pipe.wait == null);
     try testing.expectEqual(@as(usize, 0), h.session.pipe_tasks.len);
     try h.pumpUntilShowsCore(&client);
 }
diff --git a/src/detached/server.zig b/src/detached/server.zig
index 9b23f8d6..2b9c9247 100644
--- a/src/detached/server.zig
+++ b/src/detached/server.zig
@@ -9,7 +9,6 @@ const wire = @import("wire.zig");
 
 const host_io = @import("../host_io.zig");
 const selection_pipe = @import("../selection_pipe.zig");
-const Pipe = @import("../Pipe.zig");
 
 const file_watch = @import("../file_watch.zig");
 
@@ -412,7 +411,7 @@ pub const Session = struct {
             s.core.update(.{ .pipe_resp = .{ .id = id, .success = false, .outputs = &.{} } });
             return;
         }
-        const request = Pipe.pipeRequest(s.core, id) orelse return;
+        const request = s.core.pipe.pipeRequest(id) orelse return;
         const job = selection_pipe.Job.copy(s.worker_gpa, request) catch |err| {
             s.core.update(.{ .pipe_resp = .{ .id = id, .success = false, .outputs = &.{} } });
             return s.core.reportError(s.core.active, "pipe", err);
@@ -1257,9 +1256,9 @@ test "detached worker setup failure completes requests without changing document
     s.core.update(.{ .key = .{ .cp = '|' } });
     s.core.update(.{ .key = .{ .cp = 't', .text = "tr a-z A-Z" } });
     s.core.update(.{ .key = .{ .cp = pardes.Key.enter } });
-    try std.testing.expect(s.core.pipe_wait != null);
+    try std.testing.expect(s.core.pipe.wait != null);
     while (s.core.nextEffect()) |effect| s.core.perform(effect);
-    try std.testing.expect(s.core.pipe_wait == null);
+    try std.testing.expect(s.core.pipe.wait == null);
     try std.testing.expectEqual(@as(usize, 0), s.pipe_tasks.len);
     try std.testing.expectEqualStrings("one\n", pane.file.?.content);
     try std.testing.expect(failing.has_induced_failure);