sessamekesh / igasync Goto Github PK

auto promise = Promise<std::unique_ptr<int>>::Create();

auto fast_task_list = TaskList::Create();
auto slow_task_list = TaskList::Create();

// A peeking callback is created. Valid.
promise->on_resolve([](const auto& val) { /* ... */ }, slow_task_list);

// A consuming callback is added. Valid. No more peeking callbacks may be added.
promise->consume([](auto val) { /* ... */ }, fast_task_list);

// The promise is resolved, enqueuing all tasks.
promise->resolve(std::make_unique<int>(5));

// The fast task list "happens" to run first, for whatever reason. Valid.
// This invokes the consuming callback. Great.
fast_task_list->run();

// The slow task list "happens" to run later, eventually. Valid.
// This invokes the peeking callback on empty data. WRONG!
slow_task_list->run();