threaded version

example.py

def fetch_from_remote(url):
    return requests.get(url).content
    
def content_generator(urls):
    with concurrent.futures.ThreadPoolExectur(max_workers=4) as pool:
        futs = [pool.submit(fetch_from_remote, url) for url in urls]
        for fut in concurrent.futures.as_completed(futs):
            yield fut.result()