From 53d47a9a5a8130e5af1215bbb2c2fb663a81dc30 Mon Sep 17 00:00:00 2001
From: "Claudius \"keldu\" Holeksa" <mail@keldu.de>
Date: Sat, 20 Jul 2024 13:29:42 +0200
Subject: wip

---
 modules/io_codec/c++/io_peer.hpp      | 3 ++-
 modules/io_codec/c++/io_peer.tmpl.hpp | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

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

diff --git a/modules/io_codec/c++/io_peer.hpp b/modules/io_codec/c++/io_peer.hpp
index ab26f61..91c6488 100644
--- a/modules/io_codec/c++/io_peer.hpp
+++ b/modules/io_codec/c++/io_peer.hpp
@@ -62,7 +62,8 @@ private:
 		size_t space() const override { return 0; }
 
 		size_t queued() const override { return 0; }
-
+	
+		error_or<void> swap(conveyor<data<Outgoing, Encoding>> &&conveyor) noexcept override { return make_error<err::not_implemented>();}
 	private:
 		streaming_io_peer<Incoming, Outgoing, Encoding,
 						  BufferT> &peer_;
diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp
index 3dc11c8..4e20bd0 100644
--- a/modules/io_codec/c++/io_peer.tmpl.hpp
+++ b/modules/io_codec/c++/io_peer.tmpl.hpp
@@ -110,7 +110,7 @@ new_streaming_io_peer(own<async_io_stream> stream) {
 	auto caf =
 		new_conveyor_and_feeder<data<Incoming>>();
 
-	return {heap<streaming_io_peer<Incoming, Outgoing, BufferT>>(
+	return {heap<streaming_io_peer<Incoming, Outgoing, Encoding,BufferT>>(
 				std::move(caf.feeder), std::move(stream)),
 			std::move(caf.conveyor)};
 }
-- 
cgit v1.2.3