Function TEST

Utilities/cmcppdap/src/chan_test.cpp:22–35

#include <thread>

TEST(ChanTest, PutTakeClose) {
  dap::Chan<int> chan;
  auto thread = std::thread([&] {
    chan.put(10);
    chan.put(20);
    chan.put(30);
    chan.close();
  });
  EXPECT_EQ(chan.take(), dap::optional<int>(10));
  EXPECT_EQ(chan.take(), dap::optional<int>(20));
  EXPECT_EQ(chan.take(), dap::optional<int>(30));
  EXPECT_EQ(chan.take(), dap::optional<int>());
  thread.join();
}