# HG changeset patch # User Waqas Hussain # Date 1288987710 -18000 # Node ID e2cc09e83a3ef3775e52ac549d36545c09343202 # Parent 90f4e6dc1c117c9625a052b2b43a2126ddac8c30 util.httpstream: A little refactoring of the coroutine control flow. diff -r 90f4e6dc1c11 -r e2cc09e83a3e util/httpstream.lua --- a/util/httpstream.lua Fri Nov 05 03:07:36 2010 +0500 +++ b/util/httpstream.lua Sat Nov 06 01:08:30 2010 +0500 @@ -7,7 +7,8 @@ module("httpstream") -local function parser(data, success_cb, parser_type) +local function parser(success_cb, parser_type) + local data = coroutine.yield(); local function readline() local pos = data:find("\r\n", nil, true); while not pos do @@ -94,14 +95,15 @@ function new(success_cb, error_cb, parser_type) local co = coroutine.create(parser); + coroutine.resume(co, success_cb, parser_type) return { feed = function(self, data) if not data then - if parser_type == "client" then coroutine.resume(co, "", success_cb, parser_type); end + if parser_type == "client" then coroutine.resume(co, ""); end co = deadroutine; return error_cb(); end - local success, result = coroutine.resume(co, data, success_cb, parser_type); + local success, result = coroutine.resume(co, data); if result then co = deadroutine; return error_cb(result);