

def receive(self, payload):
    if (not isinstance(payload, bytes)):
        payload = payload.encode('utf-8')
    if (len(payload) > 0):
        self.message_buffer += payload
        self.bytes_received += len(payload)

dataset/ETHPy150Open openxc/openxc-python/openxc/formats/base.py VehicleMessageStreamer.receive/original