24 auto taskId = AsyncQueueHelpers::create(queue, {.name =
"test", .score = 10});
27 AsyncQueueHelpers::post(queue,
29 AsyncQueueHelpers::post(queue,
40 auto taskId1 = AsyncQueueHelpers::create(queue, {.name =
"test1", .score = 10});
41 auto taskId2 = AsyncQueueHelpers::create(queue, {.name =
"test2", .score = 20});
55 auto taskId1 = AsyncQueueHelpers::create(queue, {.name =
"test1", .score = 10});
56 auto taskId2 = AsyncQueueHelpers::create(queue, {.name =
"test2", .score = 20});
59 AsyncQueueHelpers::post(
61 AsyncQueueHelpers::post(
78 auto taskId1 = AsyncQueueHelpers::create(queue, {.name =
"test1", .score = 10});
79 auto taskId2 = AsyncQueueHelpers::create(queue, {.name =
"test2", .score = 20});
80 REQUIRE(taskId1.value != taskId2.value);
100 REQUIRE(queue.
tasks.size() == 3);
102 REQUIRE(
count == 30);
103 REQUIRE(queue.
tasks.size() == 1);
105 REQUIRE(
count == 40);
106 REQUIRE(queue.
tasks.size() == 0);
115 auto taskId1 = AsyncQueueHelpers::create(queue, {.name =
"test1", .score = 10});
116 auto taskId2 = AsyncQueueHelpers::create(queue, {.name =
"test2", .score = 20});
118 AsyncQueueHelpers::post(
123 AsyncQueueHelpers::post(
129 AsyncQueueHelpers::post(
137 REQUIRE(queue.
tasks.size() == 3);
139 REQUIRE(
count == 50);
140 REQUIRE(queue.
tasks.size() == 1);
142 REQUIRE(
count == 60);
143 REQUIRE(queue.
tasks.size() == 0);
151 auto taskId1 = AsyncQueueHelpers::create(queue, {.name =
"test1", .score = 10});
154 AsyncQueueHelpers::post(
160 REQUIRE(queue.
tasks.size() == 0);
161 AsyncQueueHelpers::flushPending(queue);
162 REQUIRE(queue.
tasks.size() == 1);
164 REQUIRE(queue.
tasks.size() == 1);
166 AsyncQueueHelpers::post(
171 REQUIRE(queue.
tasks.size() == 1);
172 AsyncQueueHelpers::flushPending(queue);
173 REQUIRE(queue.
tasks.size() == 2);
175 REQUIRE(queue.
tasks.size() == 1);
176 REQUIRE(
count == 10);
178 REQUIRE(queue.
tasks.size() == 0);
179 REQUIRE(
count == 30);