| ... | ... | @@ -178,7 +178,7 @@ pub fn poll( |
| 178 | 178 | |
| 179 | 179 | if (builtin.os.tag == .windows) result.windows = .{ |
| 180 | 180 | .first_read_done = false, |
| 181 | | .overlapped = [1]os.windows.OVERLAPPED { |
| 181 | .overlapped = [1]os.windows.OVERLAPPED{ |
| 182 | 182 | mem.zeroes(os.windows.OVERLAPPED), |
| 183 | 183 | } ** enum_fields.len, |
| 184 | 184 | .active = .{ |
| ... | ... | @@ -227,7 +227,7 @@ pub fn Poller(comptime StreamEnum: type) type { |
| 227 | 227 | |
| 228 | 228 | pub fn removeAt(self: *@This(), index: u32) void { |
| 229 | 229 | std.debug.assert(index < self.count); |
| 230 | | for (index + 1 .. self.count) |i| { |
| 230 | for (index + 1..self.count) |i| { |
| 231 | 231 | self.handles_buf[i - 1] = self.handles_buf[i]; |
| 232 | 232 | self.stream_map[i - 1] = self.stream_map[i]; |
| 233 | 233 | } |
| ... | ... | @@ -241,7 +241,7 @@ pub fn Poller(comptime StreamEnum: type) type { |
| 241 | 241 | pub fn deinit(self: *Self) void { |
| 242 | 242 | if (builtin.os.tag == .windows) { |
| 243 | 243 | // cancel any pending IO to prevent clobbering OVERLAPPED value |
| 244 | | for (self.windows.active.handles_buf[0 .. self.windows.active.count]) |h| { |
| 244 | for (self.windows.active.handles_buf[0..self.windows.active.count]) |h| { |
| 245 | 245 | _ = os.windows.kernel32.CancelIo(h); |
| 246 | 246 | } |
| 247 | 247 | } |
| ... | ... | @@ -381,7 +381,7 @@ fn windowsAsyncRead( |
| 381 | 381 | overlapped: *os.windows.OVERLAPPED, |
| 382 | 382 | fifo: *PollFifo, |
| 383 | 383 | bump_amt: usize, |
| 384 | | ) !enum{ pending, closed } { |
| 384 | ) !enum { pending, closed } { |
| 385 | 385 | while (true) { |
| 386 | 386 | const buf = try fifo.writableWithSize(bump_amt); |
| 387 | 387 | var read_bytes: u32 = undefined; |