Show More
@@ -84,6 +84,9 b' class KernelActionHandler(IPythonHandler):' | |||
|
84 | 84 | |
|
85 | 85 | class ZMQChannelHandler(AuthenticatedZMQStreamHandler): |
|
86 | 86 | |
|
87 | def __repr__(self): | |
|
88 | return "%s(%s)" % (self.__class__.__name__, getattr(self, 'kernel_id', 'uninitialized')) | |
|
89 | ||
|
87 | 90 | def create_stream(self): |
|
88 | 91 | km = self.kernel_manager |
|
89 | 92 | meth = getattr(km, 'connect_%s' % self.channel) |
@@ -145,6 +148,12 b' class ZMQChannelHandler(AuthenticatedZMQStreamHandler):' | |||
|
145 | 148 | self.zmq_stream.on_recv(self._on_zmq_reply) |
|
146 | 149 | |
|
147 | 150 | def on_message(self, msg): |
|
151 | if self.zmq_stream is None: | |
|
152 | return | |
|
153 | elif self.zmq_stream.closed(): | |
|
154 | self.log.info("%s closed, closing websocket.", self) | |
|
155 | self.close() | |
|
156 | return | |
|
148 | 157 | msg = json.loads(msg) |
|
149 | 158 | self.session.send(self.zmq_stream, msg) |
|
150 | 159 |
General Comments 0
You need to be logged in to leave comments.
Login now