Allow specify schema in capnproto's stream interface

Author: lixin-wei

CMakeLists.txt

@@ -241,7 +241,12 @@ if (REFLECTCPP_CAPNPROTO)
     if (NOT TARGET CapnProto)
         find_package(CapnProto CONFIG REQUIRED)
     endif ()
-     target_link_libraries(reflectcpp PUBLIC CapnProto::kj CapnProto::capnp CapnProto::capnpc CapnProto::kj-gzip)
+    if (NOT TARGET CapnProto::capnpc)
+      # in some old versions, there is no alias target CapnProto::capnpc, fallback to capnc
+      target_link_libraries(reflectcpp PUBLIC CapnProto::kj CapnProto::capnp capnpc CapnProto::kj-gzip)
+    else()
+      target_link_libraries(reflectcpp PUBLIC CapnProto::kj CapnProto::capnp CapnProto::capnpc CapnProto::kj-gzip)
+    endif()
 endif ()
 
 if (REFLECTCPP_CBOR)

include/rfl/capnproto/read.hpp

@@ -78,6 +78,13 @@ auto read(std::istream& _stream) {
   return read<T, Ps...>(bytes.data(), bytes.size());
 }
 
+template <class T, class... Ps>
+auto read(std::istream& _stream, const Schema<T>& _schema) {
+  std::istreambuf_iterator<char> begin(_stream), end;
+  auto bytes = std::vector<char>(begin, end);
+  return read<T, Ps...>(bytes.data(), bytes.size(), _schema);
+}
+
 }  // namespace rfl::capnproto
 
 #endif

include/rfl/capnproto/write.hpp

@@ -67,6 +67,13 @@ std::ostream& write(const auto& _obj, std::ostream& _stream) {
   return _stream;
 }
 
+template <class... Ps>
+std::ostream& write(const auto& _obj, const auto& _schema, std::ostream& _stream) {
+  auto buffer = write<Ps...>(_obj, _schema);
+  _stream.write(buffer.data(), buffer.size());
+  return _stream;
+}
+
 }  // namespace rfl::capnproto
 
 #endif