diff options
author | Claudius "keldu" Holeksa <mail@keldu.de> | 2024-07-20 19:08:13 +0200 |
---|---|---|
committer | Claudius "keldu" Holeksa <mail@keldu.de> | 2024-07-20 19:08:13 +0200 |
commit | ea00856f9480abca0aa4510e09770d843176ef07 (patch) | |
tree | 964f12db39b6f0cd376f29ddb684e9c8d99e37a2 /modules/io_codec | |
parent | f802fb4d988a9b6ebfe49120343561232396cab6 (diff) |
wip
Diffstat (limited to 'modules/io_codec')
-rw-r--r-- | modules/io_codec/c++/io_peer.hpp | 14 | ||||
-rw-r--r-- | modules/io_codec/c++/io_peer.tmpl.hpp | 2 |
2 files changed, 8 insertions, 8 deletions
diff --git a/modules/io_codec/c++/io_peer.hpp b/modules/io_codec/c++/io_peer.hpp index 91c6488..f576cbe 100644 --- a/modules/io_codec/c++/io_peer.hpp +++ b/modules/io_codec/c++/io_peer.hpp @@ -8,7 +8,7 @@ namespace saw { template <typename Incoming, typename Outgoing, - typename Encoding, + typename TransportEncoding, typename ContentEncoding, typename BufferT = ring_buffer> class streaming_io_peer { public: @@ -50,7 +50,7 @@ private: : public conveyor_feeder<data<Outgoing, Encoding>> { public: peer_conveyor_feeder( - streaming_io_peer<Incoming, Outgoing, Encoding, BufferT> &peer_) + streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding, BufferT> &peer_) : peer_{peer_} {} void feed(data<Outgoing, Encoding> &&data_) override { @@ -65,7 +65,7 @@ private: error_or<void> swap(conveyor<data<Outgoing, Encoding>> &&conveyor) noexcept override { return make_error<err::not_implemented>();} private: - streaming_io_peer<Incoming, Outgoing, Encoding, + streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding, BufferT> &peer_; }; @@ -75,8 +75,8 @@ private: own<async_io_stream> io_stream_; - codec<Incoming, Encoding> in_codec_; - codec<Outgoing, Encoding> out_codec_; + codec<Incoming, TransportEncoding> in_codec_; + codec<Outgoing, TransportEncoding> out_codec_; BufferT in_buffer_; BufferT out_buffer_; @@ -92,9 +92,9 @@ private: * This is a convenience wrapper intended for a faster setup of this class */ template <typename Incoming, typename Outgoing, - typename Encoding, + typename TransportEncoding, typename ContentEncoding, typename BufferT = ring_buffer> -std::pair<own<streaming_io_peer<Incoming, Outgoing, Encoding, BufferT>>, +std::pair<own<streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding, BufferT>>, conveyor<data<Incoming, Encoding>>> new_streaming_io_peer(own<async_io_stream> stream); diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp index a3ef9b6..2babb1c 100644 --- a/modules/io_codec/c++/io_peer.tmpl.hpp +++ b/modules/io_codec/c++/io_peer.tmpl.hpp @@ -9,7 +9,7 @@ streaming_io_peer<Incoming, Outgoing, Encoding, own<async_io_stream> str) : streaming_io_peer{std::move(feed), std::move(str), {}, {}, {}, {}} {} -template <typename Incoming, typename Outgoing, typename Encoding, typename BufferT> +template <typename Incoming, typename Outgoing, typename TransportEncoding, ContentEncoding, typename BufferT> streaming_io_peer<Incoming, Outgoing, Encoding, BufferT>:: streaming_io_peer( |