diff --git a/channels/mediasetplay.py b/channels/mediasetplay.py index 4b0c2060..433dfa8b 100644 --- a/channels/mediasetplay.py +++ b/channels/mediasetplay.py @@ -155,10 +155,13 @@ def peliculas(item): contentType = '' if item.text: json = [] + itlist = [] with futures.ThreadPoolExecutor() as executor: for arg in ['searchMovie', 'searchStagioni', 'searchClip']: item.args = ['', 'search', arg] - json += executor.submit(get_programs, item).result() + itlist += [executor.submit(get_programs, item)] + for res in futures.as_completed(itlist): + json += res.result() else: json = get_programs(item) for it in json: diff --git a/channels/toonitalia.py b/channels/toonitalia.py index 4ae40694..ddec5237 100644 --- a/channels/toonitalia.py +++ b/channels/toonitalia.py @@ -34,6 +34,7 @@ def search(item, text): # item.args='search' item.text = text itemlist = [] + itlist = [] try: # item.url = host + '/lista-serie-tv/' @@ -44,7 +45,9 @@ def search(item, text): item.url = host + par[0] item.contentType = par[1] item.args = par[2] - itemlist += executor.submit(peliculas, item).result() + itlist.append(executor.submit(peliculas, item)) + for res in futures.as_completed(itlist): + itemlist += res.result() return itemlist # Continua la ricerca in caso di errore except: