| 316 | } |
| 317 | |
| 318 | ACTOR static Future<Void> consume(LocalConfigurationImpl* self, ConfigBroadcastInterface broadcaster) { |
| 319 | loop { |
| 320 | choose { |
| 321 | when(wait(consumeInternal(self, broadcaster))) { ASSERT(false); } |
| 322 | when(wait(self->kvStore->getError())) { ASSERT(false); } |
| 323 | } |
| 324 | } |
| 325 | } |
| 326 | |
| 327 | public: |
| 328 | LocalConfigurationImpl(std::string const& dataFolder, |