From d13933bc62fce71b5a58118020e0dd3776e79aa9 Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@250bpm.com>
Date: Wed, 11 Aug 2010 14:09:56 +0200
Subject: I/O object hierarchy implemented

---
 src/fq.hpp | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

(limited to 'src/fq.hpp')

diff --git a/src/fq.hpp b/src/fq.hpp
index 2e09809..97e9469 100644
--- a/src/fq.hpp
+++ b/src/fq.hpp
@@ -33,12 +33,11 @@ namespace zmq
     {
     public:
 
-        fq_t ();
+        fq_t (struct i_terminate_events *sink_);
         ~fq_t ();
 
         void attach (reader_t *pipe_);
-        bool has_pipes ();
-        void term_pipes ();
+        void terminate ();
 
         int recv (zmq_msg_t *msg_, int flags_);
         bool has_in ();
@@ -64,6 +63,12 @@ namespace zmq
         //  there are following parts still waiting in the current pipe.
         bool more;
 
+        //  Object to send events to.
+        i_terminate_events *sink;
+
+        //  If true, termination process is already underway.
+        bool terminating;
+
         fq_t (const fq_t&);
         void operator = (const fq_t&);
     };
-- 
cgit v1.2.3