@@ -202,6 +202,7 @@ pub fn request(self: *Client, req: Request) !void {
202202 notification .dispatch (.http_request_intercept , &.{ .transfer = transfer , .wait_for_interception = & wait_for_interception });
203203 if (wait_for_interception ) {
204204 self .intercepted += 1 ;
205+ log .debug (.http , "wait for interception" , .{ .intercepted = self .intercepted });
205206 if (builtin .mode == .Debug ) {
206207 transfer ._intercepted = true ;
207208 }
@@ -230,6 +231,7 @@ pub fn continueTransfer(self: *Client, transfer: *Transfer) !void {
230231 std .debug .assert (transfer ._intercepted );
231232 }
232233 self .intercepted -= 1 ;
234+ log .debug (.http , "continue transfer" , .{ .intercepted = self .intercepted });
233235 return self .process (transfer );
234236}
235237
@@ -239,6 +241,7 @@ pub fn abortTransfer(self: *Client, transfer: *Transfer) void {
239241 std .debug .assert (transfer ._intercepted );
240242 }
241243 self .intercepted -= 1 ;
244+ log .debug (.http , "abort transfer" , .{ .intercepted = self .intercepted });
242245 transfer .abort ();
243246}
244247
@@ -248,6 +251,7 @@ pub fn fulfillTransfer(self: *Client, transfer: *Transfer, status: u16, headers:
248251 std .debug .assert (transfer ._intercepted );
249252 }
250253 self .intercepted -= 1 ;
254+ log .debug (.http , "filfull transfer" , .{ .intercepted = self .intercepted });
251255 return transfer .fulfill (status , headers , body );
252256}
253257
@@ -440,6 +444,11 @@ fn processMessages(self: *Client) !void {
440444 // In this case we ignore callbacks for now.
441445 // Note: we don't deinit transfer on purpose: we want to keep
442446 // using it for the following request.
447+ self .intercepted += 1 ;
448+ log .debug (.http , "wait for auth interception" , .{ .intercepted = self .intercepted });
449+ if (builtin .mode == .Debug ) {
450+ transfer ._intercepted = true ;
451+ }
443452 self .endTransfer (transfer );
444453 continue ;
445454 }
0 commit comments