Show More
@@ -629,7 +629,7 b' class Session(Configurable):' | |||||
629 | if isinstance(socket, ZMQStream): |
|
629 | if isinstance(socket, ZMQStream): | |
630 | socket = socket.socket |
|
630 | socket = socket.socket | |
631 | try: |
|
631 | try: | |
632 | msg_list = socket.recv_multipart(mode) |
|
632 | msg_list = socket.recv_multipart(mode, copy=copy) | |
633 | except zmq.ZMQError as e: |
|
633 | except zmq.ZMQError as e: | |
634 | if e.errno == zmq.EAGAIN: |
|
634 | if e.errno == zmq.EAGAIN: | |
635 | # We can convert EAGAIN to None as we know in this case |
|
635 | # We can convert EAGAIN to None as we know in this case |
General Comments 0
You need to be logged in to leave comments.
Login now