code: async def result_processor(tasks):
      
      output = {}
      for task in tasks:
          num, res = await task
          output[num] = res
      return output
docs: An async result aggregator that combines all the results
         This gets executed in unsync.loop and unsync.thread