diff options
Diffstat (limited to 'modules/io_codec/c++')
| -rw-r--r-- | modules/io_codec/c++/io_peer.hpp | 7 | ||||
| -rw-r--r-- | modules/io_codec/c++/io_peer.tmpl.hpp | 2 |
2 files changed, 5 insertions, 4 deletions
diff --git a/modules/io_codec/c++/io_peer.hpp b/modules/io_codec/c++/io_peer.hpp index 9ba623f..a92e236 100644 --- a/modules/io_codec/c++/io_peer.hpp +++ b/modules/io_codec/c++/io_peer.hpp @@ -14,13 +14,14 @@ template <typename Codec, typename Incoming, typename Outgoing, class streaming_io_peer { public: /** - * + * Constructor with the option to provide a custom codec, in and out buffer */ streaming_io_peer( own<conveyor_feeder<heap_message_root<Incoming, InContainer>>> feed, own<async_io_stream> stream, Codec codec, BufferT in, BufferT out); + /** - * + * Constructor */ streaming_io_peer( own<conveyor_feeder<heap_message_root<Incoming, InContainer>>> feed, @@ -35,7 +36,7 @@ public: /** * Send a message to the remote peer */ - error send(heap_message_root<Outgoing, OutContainer> builder); + error_or<void> send(heap_message_root<Outgoing, OutContainer> builder); /** * A phantom conveyor feeder. Meant for interfacing with other components diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp index 880a58a..342ca42 100644 --- a/modules/io_codec/c++/io_peer.tmpl.hpp +++ b/modules/io_codec/c++/io_peer.tmpl.hpp @@ -72,7 +72,7 @@ streaming_io_peer<Codec, Incoming, Outgoing, InContainer, OutContainer, template <typename Codec, typename Incoming, typename Outgoing, typename InContainer, typename OutContainer, typename BufferT> -error streaming_io_peer<Codec, Incoming, Outgoing, InContainer, OutContainer, +error_or<void> streaming_io_peer<Codec, Incoming, Outgoing, InContainer, OutContainer, BufferT>::send(heap_message_root<Outgoing, OutContainer> msg) { bool restart_write = out_buffer_.read_segment_length() == 0; |