TySS-Dev/nearby
1
0
Fork 0
mirror of https://github.com/kidfromjupiter/nearby.git synced 2026-09-16 15:36:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add tests for Future::AddListener

Browse Source 
PiperOrigin-RevId: 470814362
This commit is contained in:
Janusz Sobczak
2022-08-29 14:25:33 -07:00
committed by Copybara-Service
parent a7c967a034
commit d7889420c4
1 changed files with 121 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/platform/future_test.cc
+121
View File
@@ -17,6 +17,7 @@
#include "gtest/gtest.h"
#include "absl/time/clock.h"
#include "absl/time/time.h"
#include "internal/platform/exception.h"
#include "internal/platform/single_thread_executor.h"
namespace location {
@@ -112,5 +113,125 @@ TEST(FutureTest, GetBlocksWhenNotReady) {
EXPECT_GE(blocked_duration, absl::Milliseconds(500));
}
TEST(FutureTest, CallsListenerOnSet) {
constexpr int kValue = 1000;
Future<int> future;
int call_count = 0;
{
SingleThreadExecutor executor;
future.AddListener(
[&]() {
ASSERT_TRUE(future.IsSet());
ASSERT_TRUE(future.Get().ok());
ASSERT_EQ(future.Get().GetResult(), kValue);
++call_count;
},
&executor);
future.Set(kValue);
// `executor` leaves scope, the destructor waits for tasks to complete
}
EXPECT_EQ(call_count, 1);
}
TEST(FutureTest, CallsAllListenersOnSet) {
constexpr int kValue = 1000;
Future<int> future;
int call_count_listener_1 = 0;
int call_count_listener_2 = 0;
{
SingleThreadExecutor executor;
future.AddListener(
[&]() {
ASSERT_TRUE(future.IsSet());
ASSERT_TRUE(future.Get().ok());
ASSERT_EQ(future.Get().GetResult(), kValue);
++call_count_listener_1;
},
&executor);
future.AddListener(
[&]() {
ASSERT_TRUE(future.IsSet());
ASSERT_TRUE(future.Get().ok());
ASSERT_EQ(future.Get().GetResult(), kValue);
++call_count_listener_2;
},
&executor);
future.Set(kValue);
// `executor` leaves scope, the destructor waits for tasks to complete
}
EXPECT_EQ(call_count_listener_1, 1);
EXPECT_EQ(call_count_listener_2, 1);
}
TEST(FutureTest, AddListenerWhenAlreadySetCallsCallback) {
constexpr int kValue = 1000;
Future<int> future;
int call_count = 0;
future.Set(kValue);
{
SingleThreadExecutor executor;
future.AddListener(
[&]() {
ASSERT_TRUE(future.IsSet());
ASSERT_TRUE(future.Get().ok());
ASSERT_EQ(future.Get().GetResult(), kValue);
++call_count;
},
&executor);
// `executor` leaves scope, the destructor waits for tasks to complete
}
EXPECT_EQ(call_count, 1);
}
TEST(FutureTest, CallsListenerOnSetException) {
constexpr Exception kException = {Exception::kFailed};
Future<int> future;
int call_count = 0;
{
SingleThreadExecutor executor;
future.AddListener(
[&]() {
ASSERT_TRUE(future.IsSet());
ASSERT_FALSE(future.Get().ok());
ASSERT_EQ(future.Get().GetException(), kException);
++call_count;
},
&executor);
future.SetException(kException);
// `executor` leaves scope, the destructor waits for tasks to complete
}
EXPECT_EQ(call_count, 1);
}
TEST(FutureTest, AddListenerWhenAlreadySetExceptionCallsCallback) {
constexpr Exception kException = {Exception::kFailed};
Future<int> future;
int call_count = 0;
future.SetException(kException);
{
SingleThreadExecutor executor;
future.AddListener(
[&]() {
ASSERT_TRUE(future.IsSet());
ASSERT_FALSE(future.Get().ok());
ASSERT_EQ(future.Get().GetException(), kException);
++call_count;
},
&executor);
// `executor` leaves scope, the destructor waits for tasks to complete
}
EXPECT_EQ(call_count, 1);
}
} // namespace nearby
} // namespace location