docs: def flush_records(self):
          """
          Send all buffered records and update the session accordingly.
          """
          s = b"".join(p.raw_stateful() for p in self.buffer_out)
          self.socket.send(s)
          self.buffer_out = []