| 179 | ThreadMultiCallback() {} |
| 180 | |
| 181 | ThreadCallback* addCallback(ThreadCallback* callback) override { |
| 182 | // May be triggered by a waitForAll on a vector with the same future in it more than once |
| 183 | UNSTOPPABLE_ASSERT(callback->getHolder(this) == nullptr); |
| 184 | |
| 185 | callback->addHolder(this, callbacks.size()); |
| 186 | callbacks.push_back(callback); |
| 187 | return (ThreadCallback*)this; |
| 188 | } |
| 189 | |
| 190 | void clearCallback(ThreadCallback* callback) override { |
| 191 | MultiCallbackHolder* h = callback->getHolder(this); |
no test coverage detected