We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6ee2ed1 commit 696c51bCopy full SHA for 696c51b
resources/site-packages/pulsar/rpc.py
@@ -90,12 +90,14 @@ def __del__(self):
90
obj.close()
91
92
93
+def _do_serve():
94
+ return not xbmc.abortRequested
95
+
96
97
def server_thread():
- import xbmc
- import bjsonrpc
98
try:
99
s = bjsonrpc.createserver(port=JSONRPC_EXT_PORT, handler_factory=PulsarRPCServer)
- s._do_serve = lambda: (not xbmc.abortRequested)
100
+ s._do_serve = _do_serve
101
log.info("pulsar: starting jsonrpc service")
102
s.serve()
103
log.info("pulsar: exiting jsonrpc service")
0 commit comments