srctree

Gregory Mullen parent 1c6d8092 e1afc44f
reset ready after consuming byte length data

src/Client.zig added: 4, removed: 3, total 1

@@ -93,6 +93,7 @@ pub fn recv(c: *Client) !Packet.Parsed {

var fr = fifo.reader();

var r = fr.any();

const reported = try Packet.unpackVarInt(&r);

ready = fifo.readableLength();

while (ready < reported) {

log.err(" getting more data... {}/{}", .{ ready, reported });

poll_more = try c.poller.poll();

src/main.zig added: 4, removed: 3, total 1

@@ -4,7 +4,7 @@

const mqtt = @import("mqtt.zig");

pub fn main() !void {

pub fn client() !void {

log.err("startup", .{});

const a = std.heap.page_allocator;