bni.py

from . import Streamer as BaseStreamer

# Berakhiran 2 byte berisi \r\n
# Network header BNI tidak memuat size data, praktis
# setiap request dianggap sebuah transaksi.

SUFFIX = b'\r\n'


class Streamer(BaseStreamer):
    def get(self, raw):
        t = raw.split(SUFFIX)
        self.raw = t[0]
        return self.raw

    def set(self, raw):
        return raw + SUFFIX