(self, ep1, ep2)
| 15 | |
| 16 | class StdBroker(object): |
| 17 | def __init__(self, ep1, ep2): |
| 18 | super(StdBroker, self).__init__() |
| 19 | |
| 20 | # always ep2 --request---> ep1 |
| 21 | # ep2 <--response-- ep1 |
| 22 | self.ep1 = self._make_transport(ep1) |
| 23 | self.ep2 = self._make_transport(ep2) |
| 24 | self.requests_map = {} # reqid -> requester cid |
| 25 | |
| 26 | self.t = threading.Thread(target=self.loop) |
| 27 | self.t.daemon = True |
| 28 | self.t.start() |
| 29 | |
| 30 | def _make_transport(self, ep): |
| 31 | ep = urlparse(ep) |
nothing calls this directly
no test coverage detected