Example: Concurrent Demo

Demonstrates concurrentDemo.zig using the canonical HTTPX API.

Complete Example

const std = @import("std");
const httpx = @import("httpx");

pub fn main() !void {
    var gpa: std.heap.DebugAllocator(.{}) = .init;
    defer _ = gpa.deinit();

    const urls = [_][]const u8{
        "http://httpbun.com/get",
        "http://httpbun.com/headers",
        "http://httpbun.com/ip",
    };

    // Run all requests concurrently (array passed directly, no explicit & needed)
    const results = httpx.getAll(urls) catch |err| {
        std.debug.print("getAll failed: {s}\n", .{@errorName(err)});
        return;
    };
    defer {
        for (results) |*r| r.deinit();
    }

    for (results, 0..) |result, i| {
        std.debug.print("Request {d}: status={d} bodyLen={d}\n", .{ i + 1, result.status, result.body.len });
    }

    // Request with options
    const reqs = [_]httpx.RequestOptions{
        .{ .method = .GET, .url = "http://httpbun.com/get" },
        .{ .method = .GET, .url = "http://httpbun.com/headers" },
        .{ .method = .GET, .url = "http://httpbun.com/ip" },
    };

    const results2 = httpx.requestAll(reqs) catch |err| {
        std.debug.print("requestAll failed: {s}\n", .{@errorName(err)});
        return;
    };
    defer {
        for (results2) |*r| r.deinit();
    }

    for (results2) |result| {
        std.debug.print("Status: {d}\n", .{result.status});
    }
}

How to Run

zig build run-concurrent-demo

Related

• Getting Started
• All Examples