add core.async for paralell processing