Submit json rpc request to input stream.
(self, method, params, request_id=None)
| 48 | self.response_thread.start() |
| 49 | |
| 50 | def submit_request(self, method, params, request_id=None): |
| 51 | """ |
| 52 | Submit json rpc request to input stream. |
| 53 | """ |
| 54 | if not method or not params: |
| 55 | raise ValueError(u'Method or Parameter was not found in request') |
| 56 | |
| 57 | request = {u'method': method, u'params': params, u'id': request_id} |
| 58 | self.request_queue.put(request) |
| 59 | |
| 60 | def request_finished(self, request_id): |
| 61 | """ |
no outgoing calls