code: async def service_observer(self, limit) -> int:
          
          if not self.isReady():
              return 0
          return await self._observer.serviceQueues(limit)
docs: Service the observer's inBox and outBox
  
          :return: the number of messages successfully serviced