super()._process_conf(conf)
+class GenericWait(BasePlugin):
+ async def _wait(self, message: Message) -> None:
+ await asyncio.sleep(message['seconds'])
+ await self._bus.send({'sender': self._name, 'id': message['id']})
+
+ def _process_conf(self, conf: PluginConfiguration) -> None:
+ receives = [{'target': self._name, 'command': 'wait',
+ 'seconds': float, 'id': str}]
+ sends = [{'id': str}]
+ self._bus.register(self._name, sends, receives, self._wait)
+ super()._process_conf(conf)
+
+
class Alias(BasePlugin):
async def _alias(self, message: Message) -> None:
alias_message = {}