async def get_iracing_data(self):
    self.ir.freeze_var_buffer_latest()
    streamable: typed_message_pb2.TypedMessage = typed_message_pb2.TypedMessage()
    streamable.type = typed_message_pb2.TypedMessage.Type.LOGGER_STREAM
    streamable.message.Pack(getInfo(ir=self.ir))
    pushable: typed_message_pb2.TypedMessage = typed_message_pb2.TypedMessage()
    pushable.type = typed_message_pb2.TypedMessage.Type.LOGGER_UPDATE
    pushable.message.Pack(getGeneral(self.ir))
    if (not self.sentGeneralData):
        (await self.streaming_queue.put(pushable.SerializeToString()))
        self.sentGeneralData = True
    (await self.streaming_queue.put(streamable.SerializeToString()))
async def get_iracing_data(self):
    self.ir.freeze_var_buffer_latest()
    streamable: typed_message_pb2.TypedMessage = typed_message_pb2.TypedMessage()
    streamable.type = typed_message_pb2.TypedMessage.Type.LOGGER_STREAM
    streamable.message.Pack(getInfo(ir=self.ir))
    pushable: typed_message_pb2.TypedMessage = typed_message_pb2.TypedMessage()
    pushable.type = typed_message_pb2.TypedMessage.Type.LOGGER_UPDATE
    pushable.message.Pack(getGeneral(self.ir))
    if (not self.sentGeneralData):
        (await self.streaming_queue.put(pushable.SerializeToString()))
        self.sentGeneralData = True
    (await self.streaming_queue.put(streamable.SerializeToString()))