@@ -317,16 +317,6 @@ const Send = struct {
317317 self .ctx .alloc ().destroy (self );
318318 }
319319
320- fn laterCbk (self : * Send , completion : * Completion , result : TimeoutError ! void ) void {
321- std .log .debug ("sending after" , .{});
322- _ = result catch | err | {
323- self .ctx .err = err ;
324- return ;
325- };
326-
327- self .ctx .loop .io .send (* Send , self , Send .asyncCbk , completion , self .ctx .socket , self .buf );
328- }
329-
330320 fn asyncCbk (self : * Send , completion : * Completion , result : SendError ! usize ) void {
331321 const size = result catch | err | {
332322 self .ctx .err = err ;
@@ -338,11 +328,6 @@ const Send = struct {
338328 }
339329};
340330
341- pub fn sendLater (ctx : * Ctx , msg : []const u8 , ns : u63 ) ! void {
342- const sd = try Send .init (ctx , msg );
343- ctx .loop .io .timeout (* Send , sd .ctx , Send .laterCbk , sd .completion , ns );
344- }
345-
346331pub fn sendAsync (ctx : * Ctx , msg : []const u8 ) ! void {
347332 const sd = try Send .init (ctx , msg );
348333 ctx .loop .io .send (* Send , sd .ctx , Send .asyncCbk , sd .completion , ctx .conn_socket , msg );
0 commit comments