wip

Author: Alex-PLACET

CMakeLists.txt

@@ -105,11 +105,11 @@ set(SPARROW_IPC_HEADERS
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/chunk_memory_serializer.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/config/config.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/config/sparrow_ipc_version.hpp
-    ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize_variable_size_binary_array.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize_fixedsizebinary_array.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize_primitive_array.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize_utils.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize_variable_size_binary_array.hpp
+    ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize_variable_size_binary_array.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/deserialize.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/encapsulated_message.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/flatbuffer_utils.hpp
@@ -121,7 +121,6 @@ set(SPARROW_IPC_HEADERS
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/serialize.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/serializer.hpp
     ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/utils.hpp
-    ${SPARROW_IPC_INCLUDE_DIR}/sparrow_ipc/concepts.hpp
 )
 
 set(SPARROW_IPC_SRC

include/sparrow_ipc/any_output_stream.hpp

@@ -124,23 +124,6 @@ namespace sparrow_ipc
          */
         [[nodiscard]] size_t size() const;
 
-        /**
-         * @brief Flushes buffered data to the underlying destination.
-         */
-        void flush();
-
-        /**
-         * @brief Closes the stream and releases resources.
-         */
-        void close();
-
-        /**
-         * @brief Checks if the stream is open.
-         *
-         * @return true if open, false otherwise
-         */
-        [[nodiscard]] bool is_open() const;
-
         /**
          * @brief Gets a reference to the underlying stream cast to the specified type.
          *
@@ -177,9 +160,6 @@ namespace sparrow_ipc
             virtual void reserve(std::size_t size) = 0;
             virtual void reserve(const std::function<std::size_t()>& calculate_reserve_size) = 0;
             [[nodiscard]] virtual size_t size() const = 0;
-            virtual void flush() = 0;
-            virtual void close() = 0;
-            [[nodiscard]] virtual bool is_open() const = 0;
         };
 
         /**
@@ -210,12 +190,6 @@ namespace sparrow_ipc
 
             [[nodiscard]] size_t size() const final;
 
-            void flush() final;
-
-            void close() final;
-
-            [[nodiscard]] bool is_open() const final;
-
             TStream& get_stream();
 
             const TStream& get_stream() const;
@@ -363,41 +337,6 @@ namespace sparrow_ipc
         }
     }
 
-    template <typename TStream>
-    void any_output_stream::stream_model<TStream>::flush()
-    {
-        if constexpr (requires(TStream& t) { t.flush(); })
-        {
-            m_stream->flush();
-        }
-        // If no flush method, do nothing
-    }
-
-    template <typename TStream>
-    void any_output_stream::stream_model<TStream>::close()
-    {
-        if constexpr (requires(TStream& t) { t.close(); })
-        {
-            m_stream->close();
-        }
-        // If no close method, do nothing
-    }
-
-    template <typename TStream>
-    bool any_output_stream::stream_model<TStream>::is_open() const
-    {
-        if constexpr (requires(const TStream& t) {
-                          { t.is_open() } -> std::convertible_to<bool>;
-                      })
-        {
-            return m_stream->is_open();
-        }
-        else
-        {
-            return true;  // Assume open if no method available
-        }
-    }
-
     template <typename TStream>
     TStream& any_output_stream::stream_model<TStream>::get_stream()
     {