diff options
Diffstat (limited to 'modules/io_codec/c++/io_peer.tmpl.hpp')
| -rw-r--r-- | modules/io_codec/c++/io_peer.tmpl.hpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp index e1863fc..26793b1 100644 --- a/modules/io_codec/c++/io_peer.tmpl.hpp +++ b/modules/io_codec/c++/io_peer.tmpl.hpp @@ -103,14 +103,14 @@ streaming_io_peer<Incoming, Outgoing, Encoding, return io_stream_->on_read_disconnected(); } -template <typename Codec, typename Incoming, typename Outgoing, typename BufferT> -std::pair<own<streaming_io_peer<Codec, Incoming, Outgoing, BufferT>>, - conveyor<data<Incoming>>> +template <typename Incoming, typename Outgoing, typename BufferT> +std::pair<own<streaming_io_peer<Incoming, Outgoing, BufferT>>, + conveyor<data<Incoming,Encoding>>> new_streaming_io_peer(own<async_io_stream> stream) { auto caf = new_conveyor_and_feeder<data<Incoming>>(); - return {heap<streaming_io_peer<Codec, Incoming, Outgoing, BufferT>>( + return {heap<streaming_io_peer<Incoming, Outgoing, BufferT>>( std::move(caf.feeder), std::move(stream)), std::move(caf.conveyor)}; } |