Document limitation

Author: andreiavrammsd

README.md

@@ -1,7 +1,7 @@
 # Channel
 
 [![build](https://github.com/andreiavrammsd/cpp-channel/actions/workflows/cmake.yml/badge.svg)](https://github.com/andreiavrammsd/cpp-channel/actions) [![codecov](https://codecov.io/github/andreiavrammsd/cpp-channel/graph/badge.svg?token=CKQ0TVW62Z)](https://codecov.io/github/andreiavrammsd/cpp-channel)
-[![documentation](https://github.com/andreiavrammsd/cpp-channel/workflows/doc/badge.svg)](https://andreiavrammsd.github.io/cpp-channel/)
+[![documentation](https://github.com/andreiavrammsd/cpp-channel/actions/workflows/doc.yml/badge.svg)](https://andreiavrammsd.github.io/cpp-channel/)
 
 ### Thread-safe container for sharing data between threads (synchronized queue). Header-only. Compatible with C++11.
 
@@ -11,7 +11,7 @@
 * Blocking (forever waiting to fetch).
 * Range-based for loop supported.
 * Close to prevent pushing and stop waiting to fetch.
-* Integrates well with STL algorithms in some cases. Eg:
+* Integrates well with STD algorithms in some cases. Eg:
     * `std::move(ch.begin(), ch.end(), ...)`
     * `std::transform(input_chan.begin(), input_chan.end(), msd::back_inserter(output_chan))`.
 * Tested with GCC, Clang, and MSVC.
@@ -136,6 +136,10 @@ int main() {
 
 See [examples](https://github.com/andreiavrammsd/cpp-channel/tree/master/examples) and [documentation](https://andreiavrammsd.github.io/cpp-channel/).
 
+## Known limitations
+
+* Integration with some STD algorithms does not compile with MSVC
+
 <br>
 
 Developed with [CLion](https://www.jetbrains.com/?from=serializer) and [Visual Studio Code](https://code.visualstudio.com/).

examples/merge_channels.cpp

@@ -37,8 +37,40 @@ int main()
     };
 
     const auto transformer = [&input_chan, &output_chan]() {
-        std::transform(input_chan.begin(), input_chan.end(), msd::back_inserter(output_chan),
-                       [](int value) { return value * 2; });
+        const auto double_value = [](int value) { return value * 2; };
+
+#ifdef _MSC_VER
+        for (auto&& value : input_chan) {
+            output_chan.write(double_value(value));
+        }
+
+        // Does not work with std::transform:
+        //
+        // could be 'void std::queue<T,std::deque<T,std::allocator<int>>>::push(int &&)'
+        //   with
+        //   [
+        //       T=ChannelTest_Traits_Test::TestBody::type
+        //   ]
+        //   D:\a\cpp-channel\cpp-channel\include\msd\channel.hpp(105,20):
+        //   'void std::queue<T,std::deque<T,std::allocator<int>>>::push(int &&)': cannot convert argument 1 from
+        //   '_OutIt' to 'int &&' with
+        //   [
+        //       T=ChannelTest_Traits_Test::TestBody::type
+        //   ]
+        //   and
+        //   [
+        //       _OutIt=msd::blocking_writer_iterator<msd::channel<ChannelTest_Traits_Test::TestBody::type>>
+        //   ]
+        //       D:\a\cpp-channel\cpp-channel\include\msd\channel.hpp(105,43):
+        //       Reason: cannot convert from '_OutIt' to 'int'
+        //   with
+        //   [
+        //       _OutIt=msd::blocking_writer_iterator<msd::channel<ChannelTest_Traits_Test::TestBody::type>>
+        //   ]
+#else
+        std::transform(input_chan.begin(), input_chan.end(), msd::back_inserter(output_chan), double_value);
+#endif  // _MSC_VER
+
         output_chan.close();
     };
 

tests/channel_test.cpp

@@ -379,8 +379,40 @@ TEST(ChannelTest, Transform)
 
     // Transform input channel values from MovableOnly to int by multiplying by 2 and write to output channel
     const auto double_transformer = [&input_chan, &output_chan]() {
-        std::transform(input_chan.begin(), input_chan.end(), msd::back_inserter(output_chan),
-                       [](auto&& value) -> int { return value.getValue() * 2; });
+        const auto double_value = [](auto&& value) -> int { return value.getValue() * 2; };
+
+#ifdef _MSC_VER
+        for (auto&& value : input_chan) {
+            output_chan.write(double_value(value));
+        }
+
+        // Does not work with std::transform:
+        //
+        // could be 'void std::queue<T,std::deque<T,std::allocator<int>>>::push(int &&)'
+        //   with
+        //   [
+        //       T=ChannelTest_Traits_Test::TestBody::type
+        //   ]
+        //   D:\a\cpp-channel\cpp-channel\include\msd\channel.hpp(105,20):
+        //   'void std::queue<T,std::deque<T,std::allocator<int>>>::push(int &&)': cannot convert argument 1 from
+        //   '_OutIt' to 'int &&' with
+        //   [
+        //       T=ChannelTest_Traits_Test::TestBody::type
+        //   ]
+        //   and
+        //   [
+        //       _OutIt=msd::blocking_writer_iterator<msd::channel<ChannelTest_Traits_Test::TestBody::type>>
+        //   ]
+        //       D:\a\cpp-channel\cpp-channel\include\msd\channel.hpp(105,43):
+        //       Reason: cannot convert from '_OutIt' to 'int'
+        //   with
+        //   [
+        //       _OutIt=msd::blocking_writer_iterator<msd::channel<ChannelTest_Traits_Test::TestBody::type>>
+        //   ]
+#else
+        std::transform(input_chan.begin(), input_chan.end(), msd::back_inserter(output_chan), double_value);
+#endif  // _MSC_VER
+
         output_chan.close();
     };