diff --git a/src/pipe.cpp b/src/pipe.cpp index e0d27872..cc7219ce 100644 --- a/src/pipe.cpp +++ b/src/pipe.cpp @@ -481,10 +481,10 @@ void zmq::pipe_t::hiccup () // Create new inpipe. if (conflate) inpipe = new (std::nothrow) - ypipe_t (); + ypipe_conflate_t (); else inpipe = new (std::nothrow) - ypipe_conflate_t (); + ypipe_t (); alloc_assert (inpipe); in_active = true;