wip

1 files changed, 11 insertions, 1 deletions

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);