aboutsummaryrefslogtreecommitdiff
path: root/misctools
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <jarred@jarredsumner.com> 2021-12-17 16:59:49 -0800
committerGravatar Jarred Sumner <jarred@jarredsumner.com> 2021-12-17 16:59:49 -0800
commit0e39174c481adeeb000fe021fa49616906fd9cd8 (patch)
tree43a4f585ad9f30aa235a35a1a5bc0cd3fbf3e081 /misctools
parent40401a6ed2b303ff2932486c6c79c1cbe658586a (diff)
downloadbun-0e39174c481adeeb000fe021fa49616906fd9cd8.tar.gz
bun-0e39174c481adeeb000fe021fa49616906fd9cd8.tar.zst
bun-0e39174c481adeeb000fe021fa49616906fd9cd8.zip
Update the misctools bins
Diffstat (limited to 'misctools')
-rw-r--r--misctools/fetch.zig10
1 files changed, 6 insertions, 4 deletions
diff --git a/misctools/fetch.zig b/misctools/fetch.zig
index ac78f745c..776ac3950 100644
--- a/misctools/fetch.zig
+++ b/misctools/fetch.zig
@@ -2,15 +2,14 @@ const std = @import("std");
usingnamespace @import("../src/global.zig");
const clap = @import("../src/deps/zig-clap/clap.zig");
-const HTTPClient = @import("../src/http/http_client_async.zig");
const URL = @import("../src/query_string_map.zig").URL;
const Headers = @import("../src/javascript/jsc/webcore/response.zig").Headers;
const Method = @import("../src/http/method.zig").Method;
const ColonListType = @import("../src/cli/colon_list_type.zig").ColonListType;
const HeadersTuple = ColonListType(string, noop_resolver);
const path_handler = @import("../src/resolver/resolve_path.zig");
-const NetworkThread = @import("../src/http/network_thread.zig");
-const HTTP = @import("../src/http/http_client_async.zig");
+const NetworkThread = @import("network_thread");
+const HTTP = @import("http");
fn noop_resolver(in: string) !string {
return in;
}
@@ -195,9 +194,12 @@ pub fn main() anyerror!void {
),
};
ctx.http.callback = HTTP.HTTPChannelContext.callback;
- ctx.http.schedule(default_allocator);
+ var batch = NetworkThread.Batch{};
+ ctx.http.schedule(default_allocator, &batch);
ctx.http.client.verbose = args.verbose;
+
ctx.http.verbose = args.verbose;
+ NetworkThread.global.pool.schedule(batch);
while (true) {
while (channel.tryReadItem() catch null) |http| {