builtin/async/init.lua

   1
   2 core.log("info", "Initializing Asynchronous environment")
   3
   4 function core.job_processor(serialized_func, serialized_param)
   5         local func = loadstring(serialized_func)
   6         local param = core.deserialize(serialized_param)
   7         local retval = nil
   8
   9         if type(func) == "function" then
  10                 retval = core.serialize(func(param))
  11         else
  12                 core.log("error", "ASYNC WORKER: Unable to deserialize function")
  13         end
  14
  15         return retval or core.serialize(nil)
  16 end
  17