2 files changed, 12 insertions, 0 deletions
diff --git a/src/zmq_decoder.cpp b/src/zmq_decoder.cpp
index 53811a1..ccaad0d 100644
--- a/src/zmq_decoder.cpp
+++ b/src/zmq_decoder.cpp
@@ -36,6 +36,16 @@ zmq::zmq_decoder_t::~zmq_decoder_t ()
     zmq_msg_close (&in_progress);
 }
 
+void zmq::zmq_decoder_t::reset ()
+{
+    //  Free and reinit message buffer.
+    zmq_msg_close (&in_progress);
+    zmq_msg_init (&in_progress);
+
+    //  Restart the FSM.
+    next_step (tmpbuf, 1, &zmq_decoder_t::one_byte_size_ready);
+}
+
 void zmq::zmq_decoder_t::set_inout (i_inout *destination_)
 {
     destination = destination_;
diff --git a/src/zmq_decoder.hpp b/src/zmq_decoder.hpp
index 16b5312..6bc373b 100644
--- a/src/zmq_decoder.hpp
+++ b/src/zmq_decoder.hpp
@@ -37,6 +37,8 @@ namespace zmq
 
         void set_inout (struct i_inout *destination_);
 
+        //  Clears any partially decoded messages.
+        void reset ();
     private:
 
         bool one_byte_size_ready ();