FZjv ldZddlZddlmZddlmZddlmZddlm Z Gdde Z Gd d e Z y) zv mygeotab.ext.feed ~~~~~~~~~~~~~~~~~ A simple data feed wrapper, written as an extension to the MyGeotab API object. N)Thread)sleep)api)ConnectionErrorcpeZdZdZej ZejdZejdZ y)DataFeedListenerz)The abstract DataFeedListener to overridecy)z]Called when rows of data are received. :param data: A list of data objects. N)selfdatas SC:\Users\Rodrigo\frota-trucks-cliente\python\Lib\site-packages\mygeotab/ext/feed.pyon_datazDataFeedListener.on_datas cy)zCalled when server errors are encountered. Return False to close the stream. :rtype: bool :param error: The error object. :return: If True, keep listening. If False, stop the data feed. Fr )r errors r on_errorzDataFeedListener.on_errorsrN) __name__ __module__ __qualname____doc__abcABCMeta __metaclass__abstractmethodrrr rr rrs@3KKM rrc&eZdZdZddZdZddZy)DataFeedzwA simple wrapper for the MyGeotab Data Feed. Create a listener that inherits from DataFeedListener to pass in. Nc||_||_||_||_||_||_d|_d|_d|_y)a}Initializes the DataFeed object. :param client_api: The MyGeotab API object. :param listener: The custom DataFeedListener object. :param type_name: The type of entity. :param interval: The data retrieval interval (in seconds). :param search: The search object. :param results_limit: The maximum number of records to return. FN) client_apilistener type_nameintervalsearch results_limitrunning_version_thread)r rrr r!r"r#s r __init__zDataFeed.__init__/sD%  "   *   rc|jr |jjd|j|j|j |j }|d|_|jj|d|js d|_yt|j|jrd|_y#tjtf$r3}|jj|dur Yd}~d|_yYd}~d}~wwxYw)zRunner for the Data Feed.GetFeed)r r" from_versionr# toVersionr FN)r$rcallr r"r%r#rrrMyGeotabExceptionrrrr!)r result exceptions r _runz DataFeed._runCsll --"nn;;!%"&"4"4 .!'{ 3  %%fVn5<<  $-- !ll" ))?; ==)))4= > sA0B==D DD cd|_|r6t|j|_|jj y|jy)zZStart the data feed. :param threaded: If True, run in a separate thread. T)targetN)r$rr0r&start)r threadeds r r3zDataFeed.startXs7  !3DL LL   IIKr)NN)T)rrrrr'r0r3r rr rr*s(* rr) rr threadingrtimermygeotabrrequests.exceptionsrobjectrrr rr r:s3 /v08v8r