def _wrap_callback_parse_time_info(subscription, on_data, message):
    """
    Wraps a user callback to parse TimeInfo
    from a WebSocket data message
    """
    if message.type == message.REPLY:
        time_response = web_pb2.TimeSubscriptionResponse()
        time_response.ParseFromString(message.reply.data)
        time = parse_isostring(time_response.timeInfo.currentTimeUTC)
        #pylint: disable=protected-access
        subscription._process(time)
        if on_data:
            on_data(time)
    elif message.type == message.DATA:
        if message.data.type == yamcs_pb2.TIME_INFO:
            time_message = getattr(message.data, 'timeInfo')
            time = parse_isostring(time_message.currentTimeUTC)
            #pylint: disable=protected-access
            subscription._process(time)
            if on_data:
                on_data(time)
def _wrap_callback_parse_time_info ( subscription , on_data , message ) : if message . type == message . REPLY : time_response = web_pb2 . TimeSubscriptionResponse ( ) time_response . ParseFromString ( message . reply . data ) time = parse_isostring ( time_response . timeInfo . currentTimeUTC ) subscription . _process ( time ) if on_data : on_data ( time ) elif message . type == message . DATA : if message . data . type == yamcs_pb2 . TIME_INFO : time_message = getattr ( message . data , 'timeInfo' ) time = parse_isostring ( time_message . currentTimeUTC ) subscription . _process ( time ) if on_data : on_data ( time )
Wraps a user callback to parse TimeInfo
    from a WebSocket data message