Show More
@@ -18,10 +18,10 b' class SubSocketChannel2p(SubSocketChannel):' | |||||
18 | self.queue.put(Message(msg)) |
|
18 | self.queue.put(Message(msg)) | |
19 |
|
19 | |||
20 | def get_msg(self): |
|
20 | def get_msg(self): | |
21 |
return self.queue.get( |
|
21 | return self.queue.get() | |
22 |
|
22 | |||
23 | def was_called(self): |
|
23 | def was_called(self): | |
24 |
return self.queue. |
|
24 | return not self.queue.empty() | |
25 |
|
25 | |||
26 | class XReqSocketChannel2p(XReqSocketChannel): |
|
26 | class XReqSocketChannel2p(XReqSocketChannel): | |
27 | #--------------------------------------------------------------------------- |
|
27 | #--------------------------------------------------------------------------- | |
@@ -34,10 +34,10 b' class XReqSocketChannel2p(XReqSocketChannel):' | |||||
34 | self.queue.put(Message(msg)) |
|
34 | self.queue.put(Message(msg)) | |
35 |
|
35 | |||
36 | def get_msg(self): |
|
36 | def get_msg(self): | |
37 |
return self.queue.get( |
|
37 | return self.queue.get() | |
38 |
|
38 | |||
39 | def was_called(self): |
|
39 | def was_called(self): | |
40 |
return self.queue. |
|
40 | return not self.queue.empty() | |
41 |
|
41 | |||
42 | class RepSocketChannel2p(RepSocketChannel): |
|
42 | class RepSocketChannel2p(RepSocketChannel): | |
43 | #--------------------------------------------------------------------------- |
|
43 | #--------------------------------------------------------------------------- |
General Comments 0
You need to be logged in to leave comments.
Login now