Show More
| @@ -297,11 +297,9 b' class TestSession(SessionTestCase):' | |||||
| 297 | msg = self.session.msg('execute', content=dict(a=10)) |
|
297 | msg = self.session.msg('execute', content=dict(a=10)) | |
| 298 | msg_list = [self.session.pack(msg[part]) for part in |
|
298 | msg_list = [self.session.pack(msg[part]) for part in | |
| 299 | ['header', 'parent_header', 'metadata', 'content']] |
|
299 | ['header', 'parent_header', 'metadata', 'content']] | |
| 300 | print("old:", msg_list) |
|
|||
| 301 | self.session.send_raw(A, msg_list, ident=b'foo') |
|
300 | self.session.send_raw(A, msg_list, ident=b'foo') | |
| 302 |
|
301 | |||
| 303 | ident, new_msg_list = self.session.feed_identities(B.recv_multipart()) |
|
302 | ident, new_msg_list = self.session.feed_identities(B.recv_multipart()) | |
| 304 | print("new:", new_msg_list) |
|
|||
| 305 | new_msg = self.session.unserialize(new_msg_list) |
|
303 | new_msg = self.session.unserialize(new_msg_list) | |
| 306 | self.assertEqual(ident[0], b'foo') |
|
304 | self.assertEqual(ident[0], b'foo') | |
| 307 | self.assertEqual(new_msg['msg_type'],msg['msg_type']) |
|
305 | self.assertEqual(new_msg['msg_type'],msg['msg_type']) | |
General Comments 0
You need to be logged in to leave comments.
Login now