Test push and fetch with buffered channel

.github/workflows/cmake.yml

@@ -102,11 +102,11 @@ jobs:
 
       - name: Build
         working-directory: ${{github.workspace}}/build
-        run: cmake --build . --config Debug --target tests
+        run: cmake --build . --config Debug --target tests -j
 
       - name: Test
         working-directory: ${{github.workspace}}/build
-        run: ctest -C Debug --verbose -R channel_test
+        run: ctest -C Debug --verbose -R channel_test -j
 
       - name: Upload coverage reports to Codecov
         uses: codecov/codecov-action@v5

tests/channel_test.cpp

@@ -49,6 +49,39 @@ TEST(ChannelTest, PushAndFetch)
     EXPECT_EQ(4, out);
 }
 
+TEST(ChannelTest, PushAndFetchWithBufferedChannel)
+{
+    msd::channel<int> channel{2};
+
+    auto push = [&channel]() {
+        channel << 1;
+        channel << 2;
+        channel << 3;
+    };
+
+    auto read = [&channel]() {
+        // Wait before reading to test the case where the channel is full and waiting
+        // for the reader to read some items.
+        std::this_thread::sleep_for(std::chrono::milliseconds(100));
+
+        int out = 0;
+
+        channel >> out;
+        EXPECT_EQ(1, out);
+
+        channel >> out;
+        EXPECT_EQ(2, out);
+
+        channel >> out;
+        EXPECT_EQ(3, out);
+    };
+
+    std::thread push_thread{push};
+    std::thread read_thread{read};
+    push_thread.join();
+    read_thread.join();
+}
+
 TEST(ChannelTest, PushAndFetchMultiple)
 {
     msd::channel<int> channel;