code: async def service_observable(self, limit) -> int:
          
          if not self.isReady():
              return 0
          o = self._service_observable_out_box(limit)
          i = await self._observable.serviceQueues(limit)
          return o + i
docs: Service the observable's inBox and outBox
  
          :return: the number of messages successfully serviced