| 13 | |
| 14 | template <typename DataType, typename UpdateType> |
| 15 | void Changes::Manager<DataType, UpdateType>::updated( |
| 16 | not_null<DataType*> data, |
| 17 | Flags flags, |
| 18 | bool dropScheduled) { |
| 19 | sendRealtimeNotifications(data, flags); |
| 20 | if (dropScheduled) { |
| 21 | const auto i = _updates.find(data); |
| 22 | if (i != _updates.end()) { |
| 23 | flags |= i->second; |
| 24 | _updates.erase(i); |
| 25 | } |
| 26 | _stream.fire({ data, flags }); |
| 27 | } else { |
| 28 | _updates[data] |= flags; |
| 29 | } |
| 30 | } |
| 31 | |
| 32 | template <typename DataType, typename UpdateType> |
| 33 | void Changes::Manager<DataType, UpdateType>::sendRealtimeNotifications( |
no test coverage detected