| 87 | return new_updates_value |
| 88 | |
| 89 | def append(self, item): |
| 90 | self._deque.append(item) |
| 91 | if self._clear_all_updates: |
| 92 | self._clear_all_updates = False |
| 93 | self._clear_updates_by_symbol.clear() |
| 94 | self._all_new_updates = 0 |
| 95 | self._new_updates_by_symbol.clear() |
| 96 | if self._clear_updates_by_symbol.get(item['symbol']): |
| 97 | self._clear_updates_by_symbol[item['symbol']] = False |
| 98 | self._new_updates_by_symbol[item['symbol']] = 0 |
| 99 | self._new_updates_by_symbol[item['symbol']] = self._new_updates_by_symbol.get(item['symbol'], 0) + 1 |
| 100 | self._all_new_updates = (self._all_new_updates or 0) + 1 |
| 101 | |
| 102 | |
| 103 | class ArrayCacheByTimestamp(BaseCache): |