code: def on_records(self, records):
          
          handler = self.handlers.get("on_records")
          if callable(handler):
              handler(records)
docs: Called when one or more RECORD messages have been received.