different fixes to req/rep

1 files changed, 3 insertions, 11 deletions

diff --git a/src/sub.cpp b/src/sub.cpp
index 73510c6..66aa8fd 100644
--- a/src/sub.cpp
+++ b/src/sub.cpp
@@ -24,11 +24,13 @@
 #include "pipe.hpp"
 
 zmq::sub_t::sub_t (class app_thread_t *parent_) :
-    socket_base_t (parent_, ZMQ_SUB),
+    socket_base_t (parent_),
     active (0),
     current (0),
     all_count (0)
 {
+    options.requires_in = true;
+    options.requires_out = false;
 }
 
 zmq::sub_t::~sub_t ()
@@ -38,16 +40,6 @@ zmq::sub_t::~sub_t ()
     in_pipes.clear ();
 }
 
-bool zmq::sub_t::xrequires_in ()
-{
-    return true;
-}
-
-bool zmq::sub_t::xrequires_out ()
-{
-    return false;
-}
-
 void zmq::sub_t::xattach_pipes (class reader_t *inpipe_,
     class writer_t *outpipe_)
 {