code: def handle_read(self, *args, **kwargs):
          
          self.read_events()
          self.process_events()
          if self.handle_read_callback is not None:
              self.handle_read_callback(self)
docs: See comment in AsyncNotifier.