proxygen
UnwrapTest.cpp
Go to the documentation of this file.
1 /*
2  * Copyright 2015-present Facebook, Inc.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 
17 #include <folly/futures/Future.h>
19 
20 using namespace folly;
21 
22 // A simple scenario for the unwrap call, when the promise was fulfilled
23 // before calling to unwrap.
24 TEST(Unwrap, simpleScenario) {
25  Future<int> encapsulated_future = makeFuture(5484);
26  Future<Future<int>> future = makeFuture(std::move(encapsulated_future));
27  EXPECT_EQ(5484, std::move(future).unwrap().value());
28 }
29 
30 // Makes sure that unwrap() works when chaning Future's commands.
31 TEST(Unwrap, chainCommands) {
32  Future<Future<int>> future = makeFuture(makeFuture(5484));
33  auto unwrapped = std::move(future).unwrap().then([](int i) { return i; });
34  EXPECT_EQ(5484, unwrapped.value());
35 }
36 
37 // Makes sure that the unwrap call also works when the promise was not yet
38 // fulfilled, and that the returned Future<T> becomes ready once the promise
39 // is fulfilled.
40 TEST(Unwrap, futureNotReady) {
42  Future<Future<int>> future = p.getFuture();
43  Future<int> unwrapped = std::move(future).unwrap();
44  // Sanity - should not be ready before the promise is fulfilled.
45  ASSERT_FALSE(unwrapped.isReady());
46  // Fulfill the promise and make sure the unwrapped future is now ready.
47  p.setValue(makeFuture(5484));
48  ASSERT_TRUE(unwrapped.isReady());
49  EXPECT_EQ(5484, unwrapped.value());
50 }
#define EXPECT_EQ(val1, val2)
Definition: gtest.h:1922
constexpr detail::Map< Move > move
Definition: Base-inl.h:2567
—— Concurrent Priority Queue Implementation ——
Definition: AtomicBitSet.h:29
Future< T > getFuture()
Definition: Promise-inl.h:97
std::enable_if< std::is_same< Unit, B >::value, void >::type setValue()
Definition: Promise.h:326
constexpr detail::Unwrap unwrap
Definition: Base-inl.h:2579
uint64_t value(const typename LockFreeRingBuffer< T, Atom >::Cursor &rbcursor)
#define ASSERT_FALSE(condition)
Definition: gtest.h:1868
#define ASSERT_TRUE(condition)
Definition: gtest.h:1865
TEST(SequencedExecutor, CPUThreadPoolExecutor)
Future< typename std::decay< T >::type > makeFuture(T &&t)
Definition: Future-inl.h:1310