all ine one

BUILDING.md

@@ -26,7 +26,8 @@ But RPP is header-only library, so, without enabling any extra options is just c
 - `RPP_BUILD_TESTS` - (ON/OFF) build unit tests (default OFF)
 - `RPP_BUILD_EXAMPLES` - (ON/OFF) build examples of usage of RPP (default OFF)
 - `RPP_BUILD_SFML_CODE` - (ON/OFF) build RPP code related to SFML or not (default OFF) - requires SFML to be installed
-- `RPP_BUILD_QT_CODE` - (ON/OFF) build RPPQT related code (examples/tests)(rppqt module doesn't requires this one) (default OFF) - requires QT5/6 to be installed
+- `RPP_BUILD_QT_CODE` - (ON/OFF) build QT related code (examples/tests)(rppqt module doesn't requires this one) (default OFF) - requires QT5/6 to be installed
+- `RPP_BUILD_GRPC_CODE` - (ON/OFF) build GRPC related code (examples/tests)(rppgrpc module doesn't requires this one) (default OFF) - requires grpc++/protobuf to be installed
 
 By default, it provides rpp and rppqt INTERFACE modules.
 

CMakePresets.json

@@ -138,6 +138,13 @@
         "RPP_BUILD_QT_CODE" : "ON"
       }
     },
+    {
+      "name" : "build-grpc",
+      "hidden": true,
+      "cacheVariables": {
+        "RPP_BUILD_GRPC_CODE" : "ON"
+      }
+    },
     {
       "name" : "use-conan",
       "hidden": true,
@@ -149,6 +156,7 @@
     },
     {
       "name": "build-dir",
+      "hidden": true,
       "binaryDir": "${sourceDir}/build"
     },
 
@@ -160,7 +168,7 @@
     },
     {
       "name": "ci-coverage-gcc",
-      "inherits": ["ci-build", "build-tests", "build-qt", "ci-unix", "ci-gcc"],
+      "inherits": ["ci-build", "build-tests", "build-qt", "build-grpc", "ci-unix", "ci-gcc"],
       "cacheVariables": {
         "RPP_ENABLE_COVERAGE": "ON",
         "CMAKE_CXX_FLAGS": "-O0 -g --coverage -fkeep-inline-functions -fkeep-static-functions -fprofile-arcs -ftest-coverage -fno-inline -fno-omit-frame-pointer -fno-optimize-sibling-calls",
@@ -171,7 +179,7 @@
     },
     {
       "name": "ci-coverage-clang",
-      "inherits": ["ci-build", "build-tests", "build-qt", "ci-unix", "ci-clang"],
+      "inherits": ["ci-build", "build-tests", "build-qt", "build-grpc", "ci-unix", "ci-clang"],
       "cacheVariables": {
         "RPP_ENABLE_COVERAGE": "ON",
         "CMAKE_CXX_FLAGS": "-fprofile-instr-generate -fcoverage-mapping",
@@ -182,58 +190,58 @@
     },
     {
       "name": "ci-sanitize-tsan",
-      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "ci-unix", "ci-clang"],
+      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "build-grpc", "ci-unix", "ci-clang"],
       "cacheVariables": {
         "CMAKE_CXX_FLAGS": "-fsanitize=thread -g -O1"
       }
     },
     {
       "name": "ci-sanitize-asan",
-      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "ci-unix", "ci-clang"],
+      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "build-grpc", "ci-unix", "ci-clang"],
       "cacheVariables": {
         "CMAKE_CXX_FLAGS": "-fsanitize=address -fno-optimize-sibling-calls -fsanitize-address-use-after-scope -fno-omit-frame-pointer -g -O1"
       }
     },
     {
       "name": "ci-sanitize-lsan",
-      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "ci-unix", "ci-clang"],
+      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "build-grpc", "ci-unix", "ci-clang"],
       "cacheVariables": {
         "CMAKE_CXX_FLAGS": "-fsanitize=leak -fno-omit-frame-pointer -g -O1"
       }
     },
     {
       "name": "ci-sanitize-msan",
-      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "ci-unix", "ci-clang"],
+      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "build-grpc", "ci-unix", "ci-clang"],
       "cacheVariables": {
         "CMAKE_CXX_FLAGS": "-fsanitize=memory -fno-optimize-sibling-calls -fsanitize-memory-track-origins=2 -fno-omit-frame-pointer -g -O2"
       }
     },
     {
       "name": "ci-sanitize-ubsan",
-      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "ci-unix", "ci-clang"],
+      "inherits": ["ci-build", "build-tests", "build-benchmarks", "build-qt", "build-grpc", "ci-unix", "ci-clang"],
       "cacheVariables": {
         "CMAKE_CXX_FLAGS": "-fsanitize=undefined"
       }
     },
     {
       "name": "ci-macos-tests",
-      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-sfml", "ci-unix"]
+      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-grpc", "build-sfml", "ci-unix"]
     },
     {
       "name": "ci-ubuntu-clang-tests",
-      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-sfml", "ci-unix", "ci-clang", "cppcheck", "clang-tidy"]
+      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-grpc", "build-sfml", "ci-unix", "ci-clang", "cppcheck", "clang-tidy"]
     },
     {
       "name": "ci-ubuntu-gcc-tests",
-      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-sfml", "ci-unix", "ci-gcc", "cppcheck", "clang-tidy"]
+      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-grpc", "build-sfml", "ci-unix", "ci-gcc", "cppcheck", "clang-tidy"]
     },
     {
       "name": "ci-windows-tests",
-      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-sfml", "ci-win64"]
+      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-grpc", "build-sfml", "ci-win64"]
     },
     {
       "name": "ci-ubuntu-clang-tests-no-checks",
-      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-sfml", "ci-unix", "ci-clang" ]
+      "inherits": ["ci-build", "build-tests", "build-examples", "build-qt", "build-grpc", "build-sfml", "ci-unix", "ci-clang" ]
     },
 
 

Doxyfile

@@ -947,6 +947,7 @@ INPUT                  = src/rpp \
                          src/extensions \
                          src/examples/rpp/doxygen \
                          src/examples/rppqt/doxygen \
+                         src/examples/rppgrpc/doxygen \
                          docs
 
 # This tag can be used to specify the character encoding of the source files
@@ -1078,7 +1079,8 @@ EXCLUDE_SYMBOLS        =
 # command).
 
 EXAMPLE_PATH           = src/examples/rpp/doxygen \
-                         src/examples/rppqt/doxygen
+                         src/examples/rppqt/doxygen \
+                         src/examples/rppgrpc/doxygen
 
 # If the value of the EXAMPLE_PATH tag contains directories, you can use the
 # EXAMPLE_PATTERNS tag to specify one or more wildcard pattern (like *.cpp and

Readme.md

@@ -32,6 +32,7 @@ rpp::source::from_callable(&::getchar)
 
 There we are creating observable (soure of emissions/values/data) to emit value via invoking of `getchar` function, `repeat`-ing it infinite amount of time till termination event happening. It emits values while symbol is not equal to `0`, takeing only **not** digits, maping them to upper case and then just printing to console.
 
+<<<<<<< HEAD
 
 Also RPP supports QT out of box. Checkout [RPPQT reference](https://victimsnino.github.io/ReactivePlusPlus/v2/docs/html/group__rppqt.html). For example:
 ```cpp
@@ -47,6 +48,40 @@ rppqt::source::from_signal(*button, &QPushButton::clicked); // <------ react on
    {
       clicks_count_label->setText(QString{"Clicked %1 times in total!"}.arg(clicks));
    });
+=======
+## QT
+Also it supports QT out of box. Checkout [RPPQT reference](https://victimsnino.github.io/ReactivePlusPlus/v2/docs/html/group__rppqt.html)
+
+```cpp
+auto button = new QPushButton("Click me!");
+auto label  = new QLabel();
+
+rppqt::source::from_signal(*button, &QPushButton::clicked);
+   | rpp::operators::observe_on(rpp::schedulers::new_thread{})
+   // some heavy job
+   | rpp::operators::scan(0, [](int seed, auto) { return ++seed; })
+   | rpp::operators::observe_on(rppqt::schedulers::main_thread_scheduler{}) // <--- go back to main QT scheduler
+   | rpp::operators::subscribe([&clicks_count_label](int clicks)
+   {
+      clicks_count_label->setText(QString{"Clicked %1 times in total!"}.arg(clicks));
+   });
+```
+
+<!-- ## GRPC -->
+<!-- RPP also supports GRPC out of box! Checkout [GRPC reference](https://victimsnino.github.io/ReactivePlusPlus/v2/docs/html/group__rppgrpc.html) -->
+
+## Why do you need it?
+
+Check the [User Guide](https://victimsnino.github.io/ReactivePlusPlus/v2/docs/html/md_docs_2readme.html) for a detailed overview of the Reactive Programming concept and RPP itself.
+
+In short, RPP can help you build complex pipelines to distribute values over time, connect "some sources of data" without directly connecting them.
+
+Take a look at the example code for  QT. Here, you can see how to connect a button to a label and update it based on the number of clicks.
+```cpp
+auto button          = new QPushButton("Click me!");
+auto clicks_count_label = new QLabel();
+rppqt::source::from_signal(*button_1, &QPushButton::clicked);
+>>>>>>> 9561a40d (all ine one)
 ```
 
 ## What about existing Reactive Extension libraries for C++?

cmake/dependencies.cmake

@@ -14,6 +14,33 @@ macro(rpp_handle_3rdparty TARGET_NAME)
   set_target_properties(${TARGET_NAME} PROPERTIES INTERFACE_SYSTEM_INCLUDE_DIRECTORIES $<TARGET_PROPERTY:${TARGET_NAME},INTERFACE_INCLUDE_DIRECTORIES>)
 endmacro()
 
+macro(rpp_fetch_library_extended NAME URL TAG TARGET_NAME)
+  Include(FetchContent)
+  set(BUILD_SHARED_LIBS OFF CACHE INTERNAL "Build SHARED libraries")
+
+  Set(FETCHCONTENT_QUIET FALSE)
+
+  FetchContent_Declare(
+    ${NAME}
+    GIT_REPOSITORY ${URL}
+    GIT_TAG        ${TAG}
+    GIT_SHALLOW    TRUE
+    GIT_PROGRESS   TRUE
+    GIT_SUBMODULES ""
+  )
+
+  FetchContent_MakeAvailable(${NAME})
+  rpp_handle_3rdparty(${TARGET_NAME})
+endmacro()
+
+macro(rpp_fetch_library NAME URL TAG)
+  find_package(${NAME} QUIET)
+  if (NOT ${NAME}_FOUND)
+    message("-- RPP: Fetching ${NAME}...")
+    rpp_fetch_library_extended(${NAME} ${URL} ${TAG} ${NAME})
+  endif()
+endmacro()
+
 # ===================== SFML =======================
 if (RPP_BUILD_SFML_CODE AND RPP_BUILD_EXAMPLES)
     find_package(SFML COMPONENTS graphics system window REQUIRED)
@@ -42,32 +69,44 @@ if (RPP_BUILD_QT_CODE AND (RPP_BUILD_TESTS OR RPP_BUILD_EXAMPLES))
   endmacro()
 endif()
 
-macro(rpp_fetch_library_extended NAME URL TAG TARGET_NAME)
-  Include(FetchContent)
-  set(BUILD_SHARED_LIBS OFF CACHE INTERNAL "Build SHARED libraries")
+# ========================== GRPC ====================================
+if (RPP_BUILD_GRPC_CODE AND (RPP_BUILD_TESTS OR RPP_BUILD_EXAMPLES))
+  find_package(Protobuf CONFIG REQUIRED)
+  find_package(gRPC CONFIG REQUIRED)
 
-  Set(FETCHCONTENT_QUIET FALSE)
+  rpp_handle_3rdparty(gRPC::grpc++)
+  rpp_handle_3rdparty(protobuf::protobuf)
 
-  FetchContent_Declare(
-    ${NAME}
-    GIT_REPOSITORY ${URL}
-    GIT_TAG        ${TAG}
-    GIT_SHALLOW    TRUE
-    GIT_PROGRESS   TRUE
-    GIT_SUBMODULES ""
-  )
+  macro(rpp_add_proto_target TARGET FILES)
+    add_library(${TARGET} STATIC ${FILES})
 
-  FetchContent_MakeAvailable(${NAME})
-  rpp_handle_3rdparty(${TARGET_NAME})
-endmacro()
+    target_link_libraries(${TARGET}
+        PUBLIC
+            gRPC::grpc++
+            protobuf::libprotobuf
+            ${grpc_LIBRARIES_TARGETS}
+    )
 
-macro(rpp_fetch_library NAME URL TAG)
-  find_package(${NAME} QUIET)
-  if (NOT ${NAME}_FOUND)
-    message("-- RPP: Fetching ${NAME} from ${URL} by ${TAG}...")
-    rpp_fetch_library_extended(${NAME} ${URL} ${TAG} ${NAME})
-  endif()
-endmacro()
+    target_include_directories(${TARGET} PUBLIC ${CMAKE_CURRENT_BINARY_DIR})
+
+    get_target_property(grpc_cpp_plugin_location gRPC::grpc_cpp_plugin LOCATION )
+    protobuf_generate(TARGET ${TARGET} OUT_VAR PROTO_FILES LANGUAGE cpp )
+
+    protobuf_generate(
+        TARGET ${TARGET}
+        LANGUAGE grpc
+        OUT_VAR GRPC_PROTO_FILES
+        # PROTOC_OUT_DIR "${PROTO_BINARY_DIR}"
+        PLUGIN protoc-gen-grpc=${grpc_cpp_plugin_location}
+        GENERATE_EXTENSIONS .grpc.pb.h .grpc.pb.cc)
+
+
+    set_target_properties(${TARGET} PROPERTIES INTERFACE_SYSTEM_INCLUDE_DIRECTORIES $<TARGET_PROPERTY:${TARGET},INTERFACE_INCLUDE_DIRECTORIES>)
+    set_target_properties(${TARGET} PROPERTIES CXX_CLANG_TIDY "")
+    set_target_properties(${TARGET} PROPERTIES CXX_CPPCHECK "")
+  endmacro()
+endif()
+>>>>>>> 9561a40d (all ine one)
 
 # ==================== RXCPP =======================
 if (RPP_BUILD_RXCPP AND RPP_BUILD_BENCHMARKS)

cmake/install-rules.cmake

@@ -8,6 +8,7 @@ install(
     DIRECTORY
        src/rpp
        src/extensions/rppqt
+       src/extensions/rppgrpc
     DESTINATION
         "${CMAKE_INSTALL_INCLUDEDIR}"
     COMPONENT
@@ -25,6 +26,11 @@ install(
     EXPORT RPPTargets
     INCLUDES DESTINATION "${CMAKE_INSTALL_INCLUDEDIR}/rppqt"
 )
+install(
+    TARGETS rppgrpc
+    EXPORT RPPTargets
+    INCLUDES DESTINATION "${CMAKE_INSTALL_INCLUDEDIR}/rppgrpc"
+)
 
 write_basic_package_version_file(
     "${package}ConfigVersion.cmake"

cmake/variables.cmake

@@ -82,6 +82,7 @@ endfunction()
 # ------------ Options to tweak ---------------------
 option(RPP_BUILD_SFML_CODE "Enable SFML support in examples/code." OFF)
 option(RPP_BUILD_QT_CODE "Enable QT support in examples/code." OFF)
+option(RPP_BUILD_GRPC_CODE "Enable grpc++ support in examples/code." OFF)
 
 if (RPP_DEVELOPER_MODE)
   option(RPP_BUILD_TESTS      "Build unit tests tree." OFF)
@@ -100,6 +101,9 @@ if (RPP_DEVELOPER_MODE)
     if (RPP_BUILD_BENCHMARKS)
       set(CONAN_ARGS "${CONAN_ARGS};-o rpp/*:with_benchmarks=True")
     endif()
+    if (RPP_BUILD_GRPC_CODE)
+      set(CONAN_ARGS "${CONAN_ARGS};-o rpp/*:with_grpc=True")
+    endif()
   endif()
 
   if(RPP_ENABLE_COVERAGE)

conanfile.py

@@ -32,10 +32,10 @@ def requirements(self):
         if self.options.with_sfml:
             self.requires("sfml/2.6.1", options={"audio": False})
 
-        # if self.options.with_grpc:
-            # self.requires("grpc/1.54.3", transitive_libs=True, transitive_headers=True)
-            # self.requires("protobuf/3.21.12")
-            # self.requires("libmount/2.39", override=True)
+        if self.options.with_grpc:
+            self.requires("grpc/1.54.3", transitive_libs=True, transitive_headers=True)
+            self.requires("protobuf/3.21.12")
+            self.requires("libmount/2.39", override=True)
 
         if self.options.with_cmake:
             self.tool_requires("cmake/3.29.3")

src/examples/CMakeLists.txt

@@ -3,3 +3,7 @@ add_subdirectory(rpp)
 if(RPP_BUILD_QT_CODE)
     add_subdirectory(rppqt)
 endif()
+
+if (RPP_BUILD_GRPC_CODE)
+    add_subdirectory(rppgrpc)
+endif()

src/examples/rppgrpc/CMakeLists.txt

@@ -0,0 +1,2 @@
+add_subdirectory(communication)
+add_subdirectory(doxygen)

src/examples/rppgrpc/communication/CMakeLists.txt

@@ -0,0 +1,9 @@
+set(TARGET rppgrpc_communication)
+
+rpp_add_proto_target(${TARGET}_proto protocol.proto)
+
+add_executable(${TARGET}_server server.cpp)
+target_link_libraries(${TARGET}_server PRIVATE ${TARGET}_proto rppgrpc)
+
+add_executable(${TARGET}_client client.cpp)
+target_link_libraries(${TARGET}_client PRIVATE ${TARGET}_proto rppgrpc)