diff options
author | 2021-12-17 16:59:49 -0800 | |
---|---|---|
committer | 2021-12-17 16:59:49 -0800 | |
commit | 0e39174c481adeeb000fe021fa49616906fd9cd8 (patch) | |
tree | 43a4f585ad9f30aa235a35a1a5bc0cd3fbf3e081 /misctools | |
parent | 40401a6ed2b303ff2932486c6c79c1cbe658586a (diff) | |
download | bun-0e39174c481adeeb000fe021fa49616906fd9cd8.tar.gz bun-0e39174c481adeeb000fe021fa49616906fd9cd8.tar.zst bun-0e39174c481adeeb000fe021fa49616906fd9cd8.zip |
Update the misctools bins
Diffstat (limited to 'misctools')
-rw-r--r-- | misctools/fetch.zig | 10 |
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| { |