diff options
| author | Andrew Kelley <superjoe30@gmail.com> | 2018-08-02 17:29:31 -0400 |
|---|---|---|
| committer | Andrew Kelley <superjoe30@gmail.com> | 2018-08-02 17:29:31 -0400 |
| commit | 65140b2fba4e55d713de506f2bed259ca9410cbf (patch) | |
| tree | e52660c1726caabc730c8869499e5801f027f1b1 /std/event/tcp.zig | |
| parent | 951124e1772c7013c2b1a674cf98a0b638c36262 (diff) | |
| parent | fb05b96492f4fb1476106bf735788ac16f69c7ef (diff) | |
| download | zig-65140b2fba4e55d713de506f2bed259ca9410cbf.tar.gz zig-65140b2fba4e55d713de506f2bed259ca9410cbf.zip | |
Merge remote-tracking branch 'origin/master' into async-fs
Diffstat (limited to 'std/event/tcp.zig')
| -rw-r--r-- | std/event/tcp.zig | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/std/event/tcp.zig b/std/event/tcp.zig index 6757d8cc09..19cce4a5e5 100644 --- a/std/event/tcp.zig +++ b/std/event/tcp.zig @@ -88,8 +88,8 @@ pub const Server = struct { }, error.ProcessFdQuotaExceeded => { errdefer std.os.emfile_promise_queue.remove(&self.waiting_for_emfile_node); - suspend |p| { - self.waiting_for_emfile_node = PromiseNode.init(p); + suspend { + self.waiting_for_emfile_node = PromiseNode.init( @handle() ); std.os.emfile_promise_queue.append(&self.waiting_for_emfile_node); } continue; @@ -141,8 +141,8 @@ test "listen on a port, send bytes, receive bytes" { (await next_handler) catch |err| { std.debug.panic("unable to handle connection: {}\n", err); }; - suspend |p| { - cancel p; + suspend { + cancel @handle(); } } async fn errorableHandler(self: *Self, _addr: *const std.net.Address, _socket: *const std.os.File) !void { |
