zat.dev / zat
atproto utils for zig zat.dev
atproto sdk zig
26
fork

Configure Feed

Select the types of activity you want to include in your feed.

fix stream.handle → stream.socket.handle for 0.16

net.Stream.handle moved to net.Stream.socket.handle in zig 0.16.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

zzstoatzz f55b328b b495016a

+2 -2
+1 -1
src/internal/streaming/firehose.zig
··· 532 532 /// disappears without FIN/RST (network partition, crash, power loss). 533 533 /// detection time: 10s idle + 5s × 2 probes = 20s. 534 534 fn configureKeepalive(client: *websocket.Client) void { 535 - const fd = client.stream.stream.handle; 535 + const fd = client.stream.stream.socket.handle; 536 536 const builtin = @import("builtin"); 537 537 posix.setsockopt(fd, posix.SOL.SOCKET, posix.SO.KEEPALIVE, &std.mem.toBytes(@as(i32, 1))) catch return; 538 538 const tcp: i32 = @intCast(posix.IPPROTO.TCP);
+1 -1
src/internal/streaming/jetstream.zig
··· 281 281 /// disappears without FIN/RST (network partition, crash, power loss). 282 282 /// detection time: 10s idle + 5s × 2 probes = 20s. 283 283 fn configureKeepalive(client: *websocket.Client) void { 284 - const fd = client.stream.stream.handle; 284 + const fd = client.stream.stream.socket.handle; 285 285 const builtin = @import("builtin"); 286 286 posix.setsockopt(fd, posix.SOL.SOCKET, posix.SO.KEEPALIVE, &std.mem.toBytes(@as(i32, 1))) catch return; 287 287 const tcp: i32 = @intCast(posix.IPPROTO.TCP);