Source code for aj.plugins.core.api.push

from jadi import service
from aj.util import BroadcastQueue

[docs]@service class Push(): """ A service providing push messages to the client. """ def __init__(self, context): self.q = BroadcastQueue()
[docs] def register(self): return self.q.register()
[docs] def push(self, plugin, msg): """ Sends a push message to the client. :param plugin: routing ID :param msg: message """ self.q.broadcast((plugin, msg))


comments powered by Disqus