diff --git a/src/http/Client.zig b/src/http/Client.zig index 90bba041..26419b6a 100644 --- a/src/http/Client.zig +++ b/src/http/Client.zig @@ -436,6 +436,12 @@ fn robotsShutdownCallback(ctx_ptr: *anyopaque) void { ctx.robots_url, ) orelse @panic("Client.robotsErrorCallback empty queue"); defer queued.value.deinit(ctx.client.allocator); + + for (queued.value.items) |queued_req| { + if (queued_req.shutdown_callback) |shutdown_cb| { + shutdown_cb(queued_req.ctx); + } + } } fn waitForInterceptedResponse(self: *Client, transfer: *Transfer) !bool {