(self)
| 56 | return self.source.stocks(self.watch_stocks) |
| 57 | |
| 58 | def push_quotation(self): |
| 59 | while self.is_active: |
| 60 | if self.is_pause: |
| 61 | time.sleep(1) |
| 62 | continue |
| 63 | try: |
| 64 | response_data = self.fetch_quotation() |
| 65 | except aiohttp.errors.ServerDisconnectedError: |
| 66 | time.sleep(self.PushInterval) |
| 67 | continue |
| 68 | event = Event(event_type=self.EventType, data=response_data) |
| 69 | self.event_engine.put(event) |
| 70 | time.sleep(self.PushInterval) |
nothing calls this directly
no test coverage detected