Loading sjrpc/core/protocols/__init__.py +7 −0 Original line number Diff line number Diff line Loading @@ -43,6 +43,13 @@ class Protocol(object): """ return self._label def create_watcher(self, watcher_class, **kwargs): """ Create a new pyev watcher for this protocol and return it. """ kwargs['loop'] = self._connection.loop watcher = watcher_class(**kwargs) return watcher def send(self, payload): """ Send a message through the sjRpc connection. """ Loading Loading
sjrpc/core/protocols/__init__.py +7 −0 Original line number Diff line number Diff line Loading @@ -43,6 +43,13 @@ class Protocol(object): """ return self._label def create_watcher(self, watcher_class, **kwargs): """ Create a new pyev watcher for this protocol and return it. """ kwargs['loop'] = self._connection.loop watcher = watcher_class(**kwargs) return watcher def send(self, payload): """ Send a message through the sjRpc connection. """ Loading
