mirror of
https://github.com/avatao-content/baseimage-tutorial-framework
synced 2024-11-22 23:11:33 +00:00
Remove leftover ioloop.install() stuff from module global era
This commit is contained in:
parent
b75709b3e5
commit
08260f70fa
@ -1,6 +1,5 @@
|
|||||||
import zmq
|
import zmq
|
||||||
from functools import partial
|
from functools import partial
|
||||||
from zmq.eventloop import ioloop
|
|
||||||
from zmq.eventloop.zmqstream import ZMQStream
|
from zmq.eventloop.zmqstream import ZMQStream
|
||||||
|
|
||||||
from tfw.networking.serialization import serialize_all
|
from tfw.networking.serialization import serialize_all
|
||||||
@ -8,9 +7,6 @@ from tfw.config import PUBLISHER_PORT, RECEIVER_PORT
|
|||||||
from tfw.util import ZMQConnectorBase
|
from tfw.util import ZMQConnectorBase
|
||||||
|
|
||||||
|
|
||||||
ioloop.install()
|
|
||||||
|
|
||||||
|
|
||||||
class ServerDownlinkConnector(ZMQConnectorBase):
|
class ServerDownlinkConnector(ZMQConnectorBase):
|
||||||
def __init__(self, zmq_context=None):
|
def __init__(self, zmq_context=None):
|
||||||
super(ServerDownlinkConnector, self).__init__(zmq_context)
|
super(ServerDownlinkConnector, self).__init__(zmq_context)
|
||||||
|
@ -1,5 +1,4 @@
|
|||||||
import zmq
|
import zmq
|
||||||
from zmq.eventloop import ioloop
|
|
||||||
from zmq.eventloop.zmqstream import ZMQStream
|
from zmq.eventloop.zmqstream import ZMQStream
|
||||||
|
|
||||||
from tfw.networking.serialization import serialize_all
|
from tfw.networking.serialization import serialize_all
|
||||||
@ -9,9 +8,6 @@ log = logging.getLogger(__name__)
|
|||||||
from tfw.util import ZMQConnectorBase
|
from tfw.util import ZMQConnectorBase
|
||||||
|
|
||||||
|
|
||||||
ioloop.install()
|
|
||||||
|
|
||||||
|
|
||||||
class EventHandlerDownlinkConnector(ZMQConnectorBase):
|
class EventHandlerDownlinkConnector(ZMQConnectorBase):
|
||||||
def __init__(self, zmq_context=None):
|
def __init__(self, zmq_context=None):
|
||||||
super(EventHandlerDownlinkConnector, self).__init__(zmq_context)
|
super(EventHandlerDownlinkConnector, self).__init__(zmq_context)
|
||||||
|
Loading…
Reference in New Issue
Block a user