-record(consumed, {
    data :: bitstring(),
    next :: fun((integer()) -> {ok, ewe@internal@http:stream()} |
        {error, ewe@internal@http:parse_error()})
}).