Redo how we poll pipes (#1496)

* Fix pipe

* Handle unregistered

* Fix failing test

1 files changed, 28 insertions, 0 deletions

diff --git a/src/hive_array.zig b/src/hive_array.zig
index eb9220e19..39f10d324 100644
--- a/src/hive_array.zig
+++ b/src/hive_array.zig
@@ -64,6 +64,34 @@ pub fn HiveArray(comptime T: type, comptime capacity: u16) type {
             self.available.set(index);
             return true;
         }
+
+        pub const Fallback = struct {
+            hive: HiveArray(T, capacity),
+            allocator: std.mem.Allocator,
+
+            pub const This = @This();
+
+            pub fn init(allocator: std.mem.Allocator) This {
+                return .{
+                    .allocator = allocator,
+                    .hive = HiveArray(T, capacity).init(),
+                };
+            }
+
+            pub fn get(self: *This) *T {
+                if (self.hive.get()) |value| {
+                    return value;
+                }
+
+                return self.allocator.create(T) catch unreachable;
+            }
+
+            pub fn put(self: *This, value: *T) void {
+                if (self.hive.put(value)) return;
+
+                self.allocator.destroy(value);
+            }
+        };
     };
 }