diff options
Diffstat (limited to 'src/decoder.cpp')
-rw-r--r-- | src/decoder.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/decoder.cpp b/src/decoder.cpp index bcf5974..8fc1d5e 100644 --- a/src/decoder.cpp +++ b/src/decoder.cpp @@ -22,13 +22,13 @@ #include <string.h> #include "decoder.hpp" -#include "i_inout.hpp" +#include "i_engine.hpp" #include "wire.hpp" #include "err.hpp" zmq::decoder_t::decoder_t (size_t bufsize_, int64_t maxmsgsize_) : decoder_base_t <decoder_t> (bufsize_), - destination (NULL), + sink (NULL), maxmsgsize (maxmsgsize_) { int rc = in_progress.init (); @@ -44,9 +44,9 @@ zmq::decoder_t::~decoder_t () errno_assert (rc == 0); } -void zmq::decoder_t::set_inout (i_inout *destination_) +void zmq::decoder_t::set_sink (i_engine_sink *sink_) { - destination = destination_; + sink = sink_; } bool zmq::decoder_t::one_byte_size_ready () @@ -136,7 +136,7 @@ bool zmq::decoder_t::message_ready () { // Message is completely read. Push it further and start reading // new message. (in_progress is a 0-byte message after this point.) - if (!destination || !destination->write (&in_progress)) + if (!sink || !sink->write (&in_progress)) return false; next_step (tmpbuf, 1, &decoder_t::one_byte_size_ready); |