1 files changed, 6 insertions, 1 deletions
diff --git a/src/xpub.cpp b/src/xpub.cpp
index bf73399..b4bc135 100644
--- a/src/xpub.cpp
+++ b/src/xpub.cpp
@@ -37,11 +37,16 @@ xs::xpub_t::~xpub_t ()
 {
 }
 
-void xs::xpub_t::xattach_pipe (pipe_t *pipe_)
+void xs::xpub_t::xattach_pipe (pipe_t *pipe_, bool icanhasall_)
 {
     xs_assert (pipe_);
     dist.attach (pipe_);
 
+    // If icanhasall_ is specified, the caller would like to subscribe
+    // to all data on this pipe, implicitly.
+    if (icanhasall_)
+        subscriptions.add (NULL, 0, pipe_);
+
     //  The pipe is active when attached. Let's read the subscriptions from
     //  it, if any.
     xread_activated (pipe_);