std::vector<Promise<int>> promises(10);
std::vector<Future<int>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collectAll(futures);
std::vector<Promise<int>> promises(4);
std::vector<Future<int>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collectAll(futures);
std::vector<Promise<Unit>> promises(10);
std::vector<Future<Unit>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
- auto allf = collectAll(futures)
- .then([](Try<std::vector<Try<Unit>>>&& ts) {
- for (auto& f : ts.value())
- f.value();
- });
+ auto allf = collectAll(futures).then([](Try<std::vector<Try<Unit>>>&& ts) {
+ for (auto& f : ts.value()) {
+ f.value();
+ }
+ });
std::shuffle(promises.begin(), promises.end(), rng);
- for (auto& p : promises)
+ for (auto& p : promises) {
p.setValue();
+ }
EXPECT_TRUE(allf.isReady());
}
}
std::vector<Promise<int>> promises(10);
std::vector<Future<int>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collect(futures);
std::vector<Promise<int>> promises(10);
std::vector<Future<int>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collect(futures);
std::vector<Promise<Unit>> promises(10);
std::vector<Future<Unit>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collect(futures);
std::vector<Promise<Unit>> promises(10);
std::vector<Future<Unit>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collect(futures);
std::vector<Promise<std::unique_ptr<int>>> promises(10);
std::vector<Future<std::unique_ptr<int>>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
collect(futures);
}
std::iota(indices.begin(), indices.end(), 0);
std::shuffle(indices.begin(), indices.end(), rng);
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto allf = collect(futures);
std::vector<Promise<int>> promises(10);
std::vector<Future<int>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
for (auto& f : futures) {
EXPECT_FALSE(f.isReady());
std::vector<Promise<Unit>> promises(10);
std::vector<Future<Unit>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
for (auto& f : futures) {
EXPECT_FALSE(f.isReady());
std::vector<Promise<int>> promises(10);
std::vector<Future<int>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
auto anyf = collectAny(futures)
.then([](std::pair<size_t, Try<int>> p) {
TEST(Collect, alreadyCompleted) {
{
std::vector<Future<Unit>> fs;
- for (int i = 0; i < 10; i++)
+ for (int i = 0; i < 10; i++) {
fs.push_back(makeFuture());
+ }
collectAll(fs)
.then([&](std::vector<Try<Unit>> ts) {
}
{
std::vector<Future<int>> fs;
- for (int i = 0; i < 10; i++)
+ for (int i = 0; i < 10; i++) {
fs.push_back(makeFuture(i));
+ }
collectAny(fs)
.then([&](std::pair<size_t, Try<int>> p) {
std::vector<Promise<Unit>> promises(10);
std::vector<Future<Unit>> futures;
- for (auto& p : promises)
+ for (auto& p : promises) {
futures.push_back(p.getFuture());
+ }
bool flag = false;
size_t n = 3;
.then([&](std::vector<std::pair<size_t, Try<Unit>>> v) {
flag = true;
EXPECT_EQ(n, v.size());
- for (auto& tt : v)
+ for (auto& tt : v) {
EXPECT_TRUE(tt.second.hasValue());
+ }
});
promises[0].setValue();
{
folly::small_vector<Future<Unit>> futures;
- for (int i = 0; i < 10; i++)
+ for (int i = 0; i < 10; i++) {
futures.push_back(makeFuture());
+ }
auto anyf = collectAny(futures);
}
{
folly::small_vector<Future<Unit>> futures;
- for (int i = 0; i < 10; i++)
+ for (int i = 0; i < 10; i++) {
futures.push_back(makeFuture());
+ }
auto allf = collectAll(futures);
}