x

test/core/promise/BUILD

@@ -147,6 +147,7 @@ grpc_cc_test(
     deps = [
         "//:promise",
         "//src/core:map",
+        "poll_matcher"
     ],
 )
 

test/core/promise/map_test.cc

@@ -20,12 +20,13 @@
 #include "gtest/gtest.h"
 
 #include "src/core/lib/promise/promise.h"
+#include "test/core/promise/poll_matcher.h"
 
 namespace grpc_core {
 
 TEST(MapTest, Works) {
   Promise<int> x = Map([]() { return 42; }, [](int i) { return i / 2; });
-  EXPECT_EQ(x(), Poll<int>(21));
+  EXPECT_THAT(x(), IsReady(21));
 }
 
 TEST(MapTest, JustElem) {
@@ -34,6 +35,21 @@ TEST(MapTest, JustElem) {
   EXPECT_EQ(JustElem<0>()(t), 1);
 }
 
+TEST(CheckDelayedTest, SeesImmediate) {
+  auto x = CheckDelayed([]() { return 42; });
+  EXPECT_THAT(x(), IsReady(std::make_tuple(42, false)));
+}
+
+TEST(CheckDelayedTest, SeesDelayed) {
+  auto x = CheckDelayed([n = 1]() mutable -> Poll<int> {
+    if (n == 0) return 42;
+    --n;
+    return Pending{};
+  });
+  EXPECT_THAT(x(), IsPending());
+  EXPECT_THAT(x(), IsReady(std::make_tuple(42, true)));
+}
+
 }  // namespace grpc_core
 
 int main(int argc, char** argv) {

test/core/promise/observable_test.cc

@@ -140,6 +140,16 @@ TEST(ObservableTest, MultipleActivitiesWakeUp) {
   EXPECT_THAT(next2(), IsReady(2));
 }
 
+TEST(ObservableTest, NoDeadlockOnDestruction) {
+  StrictMock<MockActivity> activity;
+  Observable<int> observable(1);
+  activity.Activate();
+  {
+    auto next = observable.Next(1);
+    EXPECT_THAT(next(), IsPending());
+  }
+}
+
 class ThreadWakeupScheduler {
  public:
   template <typename ActivityType>