docs: async def observer_poll(self, message):
          """Poll observer after a delay."""
          # Sleep until we need to notify the observer.
          await asyncio.sleep(message['interval'])
  
          # Dispatch task to evaluate the observable.
          await self.channel_layer.send(
              CHANNEL_WORKER, {'type': TYPE_EVALUATE, 'observer': message['observer']}
          )