144 end |
144 end |
145 else -- Partial chunk remaining |
145 else -- Partial chunk remaining |
146 break; |
146 break; |
147 end |
147 end |
148 elseif len and #buf >= len then |
148 elseif len and #buf >= len then |
149 if packet.code == 101 then |
149 if packet.code == 101 then |
150 packet.body, buf = buf, "" |
150 packet.body, buf = buf, "" |
151 else |
151 else |
152 packet.body, buf = buf:sub(1, len), buf:sub(len + 1); |
152 packet.body, buf = buf:sub(1, len), buf:sub(len + 1); |
153 end |
153 end |
154 state = nil; success_cb(packet); |
154 state = nil; success_cb(packet); |
|
155 elseif success_on_chunk then |
|
156 packet.partial = true; |
|
157 packet.body = buf; |
|
158 success_cb(packet); |
|
159 buf = packet.body; |
155 else |
160 else |
156 break; |
161 break; |
157 end |
162 end |
158 elseif #buf >= len then |
163 elseif #buf >= len then |
159 packet.body, buf = buf:sub(1, len), buf:sub(len + 1); |
164 packet.body, buf = buf:sub(1, len), buf:sub(len + 1); |