def fetch_streams_infinite(plugin, interval):
 try:
  streams = fetch_streams(plugin)
 except PluginError as err:
  console.logger.error(u'{0}', err)
  streams = None
 if (not streams):
  console.logger.info('Waiting for streams, retrying every {0} second(s)', args.retry_streams)
 while (not streams):
  sleep(args.retry_streams)
  try:
   streams = fetch_streams(plugin)
  except PluginError as err:
   console.logger.error(u'{0}', err)
 return streams

def fetch_streams_infinite ( plugin , interval ) : try : streams = fetch_streams ( plugin ) except PluginError as err : console . logger . error ( u'{0}' , err ) streams = None if ( not streams ) : console . logger . info ( 'Waiting for streams, retrying every {0} second(s)' , args . retry_streams ) while ( not streams ) : sleep ( args . retry_streams ) try : streams = fetch_streams ( plugin ) except PluginError as err : console . logger . error ( u'{0}' , err ) return streams
attempts to fetch streams until some are returned .