From 03ed2a0fe01704f9c34b44e0963da82f894d8968 Mon Sep 17 00:00:00 2001
From: Claudius 'keldu' Holeksa <mail@keldu.de>
Date: Wed, 7 Aug 2024 17:37:47 +0200
Subject: wip

---
 modules/io_codec/c++/io_peer.tmpl.hpp | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

(limited to 'modules/io_codec/c++')

diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp
index 4deabd3..faf8c7b 100644
--- a/modules/io_codec/c++/io_peer.tmpl.hpp
+++ b/modules/io_codec/c++/io_peer.tmpl.hpp
@@ -91,7 +91,17 @@ error_or<void> streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentE
 										   msg) {
 	bool restart_write = (out_buffer_.read_segment_length() == 0u);
 
-	auto eov = out_buffer_.write_from(msg.get_buffer());
+	auto& msg_buff = msg.get_buffer();
+	{
+		auto eov = in_codec_.wrap(out_buffer_, msg_buff);
+		if(eov.is_error()){
+			auto& err = eov.get_error();
+			return std::move(err);
+		}
+		// auto& len_val = eov.get_value();
+	}
+
+	auto eov = out_buffer_.write_from(msg_buff);
 	if (eov.is_error()) {
 		auto& err = eov.get_error();
 		return std::move(err);
-- 
cgit v1.2.3