(self, oid, methodname, args, kwargs)
| 224 | return self.asyncreturn(seq) |
| 225 | |
| 226 | def asynccall(self, oid, methodname, args, kwargs): |
| 227 | request = ("CALL", (oid, methodname, args, kwargs)) |
| 228 | seq = self.newseq() |
| 229 | if threading.current_thread() != self.sockthread: |
| 230 | cvar = threading.Condition() |
| 231 | self.cvars[seq] = cvar |
| 232 | self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs) |
| 233 | self.putmessage((seq, request)) |
| 234 | return seq |
| 235 | |
| 236 | def asyncqueue(self, oid, methodname, args, kwargs): |
| 237 | request = ("QUEUE", (oid, methodname, args, kwargs)) |
no test coverage detected