From 70752027f1517f7d6088988d6832d409fcbcdae5 Mon Sep 17 00:00:00 2001 From: Pierre Tachoire Date: Tue, 19 Nov 2024 15:55:26 +0100 Subject: [PATCH] async: remove @This from SigleThreaded --- src/http/async/io.zig | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/src/http/async/io.zig b/src/http/async/io.zig index 7c2aad5b..4a11b5b6 100644 --- a/src/http/async/io.zig +++ b/src/http/async/io.zig @@ -64,10 +64,9 @@ pub const SingleThreaded = struct { cbk: Cbk, ctx: *Ctx, - const Self = @This(); const Cbk = *const fn (ctx: *Ctx, res: anyerror!void) anyerror!void; - pub fn init(loop: *Loop) Self { + pub fn init(loop: *Loop) SingleThreaded { return .{ .impl = NetworkImpl.init(loop), .cbk = undefined, @@ -76,7 +75,7 @@ pub const SingleThreaded = struct { } pub fn connect( - self: *Self, + self: *SingleThreaded, comptime _: type, ctx: *Ctx, comptime cbk: Cbk, @@ -88,13 +87,13 @@ pub const SingleThreaded = struct { self.impl.connect(self, socket, address); } - pub fn onConnect(self: *Self, err: ?anyerror) void { + pub fn onConnect(self: *SingleThreaded, err: ?anyerror) void { if (err) |e| return self.ctx.setErr(e); self.cbk(self.ctx, {}) catch |e| self.ctx.setErr(e); } pub fn send( - self: *Self, + self: *SingleThreaded, comptime _: type, ctx: *Ctx, comptime cbk: Cbk, @@ -106,14 +105,14 @@ pub const SingleThreaded = struct { self.impl.send(self, socket, buf); } - pub fn onSend(self: *Self, ln: usize, err: ?anyerror) void { + pub fn onSend(self: *SingleThreaded, ln: usize, err: ?anyerror) void { if (err) |e| return self.ctx.setErr(e); self.ctx.setLen(ln); self.cbk(self.ctx, {}) catch |e| self.ctx.setErr(e); } pub fn recv( - self: *Self, + self: *SingleThreaded, comptime _: type, ctx: *Ctx, comptime cbk: Cbk, @@ -125,7 +124,7 @@ pub const SingleThreaded = struct { self.impl.receive(self, socket, buf); } - pub fn onReceive(self: *Self, ln: usize, err: ?anyerror) void { + pub fn onReceive(self: *SingleThreaded, ln: usize, err: ?anyerror) void { if (err) |e| return self.ctx.setErr(e); self.ctx.setLen(ln); self.cbk(self.ctx, {}) catch |e| self.ctx.setErr(e);