# 
# patch "netxx_pipe.cc"
#  from [4e537bf576990197a2b4536ac29cf241d0b36183]
#    to [64762a04a86956aa54c99ee1767c192990750200]
# 
# patch "netxx_pipe.hh"
#  from [3c30849ded35bb51dabfa36d1bd012a2c0d4bc9a]
#    to [7f13e757f0721fccd410751bdcc10f2d604de2a3]
# 
========================================================================
--- netxx_pipe.cc	4e537bf576990197a2b4536ac29cf241d0b36183
+++ netxx_pipe.cc	64762a04a86956aa54c99ee1767c192990750200
@@ -200,6 +200,13 @@
   }
   return std::make_pair(socket_type(-1),ready_none);
 }
+
+void Netxx::PipeCompatibleProbe::add(PipeStream &ps, ready_type rt)
+{ assert(!is_pipe);
+  assert(!pipe);
+  is_pipe=true;
+  pipe=&ps;
+}
 #endif
 
 #ifdef BUILD_UNIT_TESTS
========================================================================
--- netxx_pipe.hh	3c30849ded35bb51dabfa36d1bd012a2c0d4bc9a
+++ netxx_pipe.hh	7f13e757f0721fccd410751bdcc10f2d604de2a3
@@ -52,7 +52,7 @@
       void clear()
       { if (is_pipe) { pipe=0; is_pipe=false; } else Probe::clear(); }
       result_type ready(const Timeout &timeout=Timeout(), ready_type rt=ready_none);
-      void add(const PipeStream &ps, ready_type rt=ready_none);
+      void add(PipeStream &ps, ready_type rt=ready_none);
       void remove(const PipeStream &ps);
       template <typename T> void add (const T &t, ready_type rt=ready_none)
       { if (is_pipe) throw std::runtime_error("stream added to a pipe probe");