We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d408d25 commit 293e159Copy full SHA for 293e159
jupyter_client/ioloop/manager.py
@@ -15,16 +15,13 @@
15
16
def as_zmqstream(f):
17
def wrapped(self, *args, **kwargs):
18
- socket = f(self, *args, **kwargs)
19
save_socket_class = None
20
# zmqstreams only support sync sockets
21
if self.context._socket_class is not zmq.Socket:
22
save_socket_class = self.context._socket_class
23
self.context._socket_class = zmq.Socket
24
try:
25
- orig_socket = socket
26
socket = f(self, *args, **kwargs)
27
- orig_socket.close()
28
finally:
29
if save_socket_class:
30
# restore default socket class
0 commit comments