diff --git a/capnp-rpc/src/local.rs b/capnp-rpc/src/local.rs
index 50ac0d128..37f1cdfea 100644
--- a/capnp-rpc/src/local.rs
+++ b/capnp-rpc/src/local.rs
@@ -126,6 +126,14 @@ impl ResultsHook for Results {
         }
     }
 
+    fn set_pipeline(&mut self, pipeline: Box<dyn PipelineHook>) {
+        todo!()
+    }
+
+    fn on_tail_call(&mut self) -> Promise<any_pointer::Pipeline, crate::Error> {
+        todo!()
+    }
+
     fn tail_call(self: Box<Self>, _request: Box<dyn RequestHook>) -> Promise<(), Error> {
         unimplemented!()
     }
diff --git a/capnp-rpc/src/rpc.rs b/capnp-rpc/src/rpc.rs
index 86d39af67..1bc1cbade 100644
--- a/capnp-rpc/src/rpc.rs
+++ b/capnp-rpc/src/rpc.rs
@@ -2140,6 +2140,7 @@ where
     variant: Option<ResultsVariant>,
     redirect_results: bool,
     answer_id: AnswerId,
+    tail_call_pipeline_fulfiller: Option<oneshot::Sender<any_pointer::Pipeline>>,
     finish_received: Rc<Cell<bool>>,
 }
 
@@ -2203,6 +2204,7 @@ where
                 redirect_results,
                 answer_id,
                 finish_received,
+                tail_call_pipeline_fulfiller: None,
             }),
             results_done_fulfiller: Some(fulfiller),
         }
@@ -2250,8 +2252,18 @@ impl<VatId> ResultsHook for Results<VatId> {
         }
     }
 
-    fn tail_call(self: Box<Self>, _request: Box<dyn RequestHook>) -> Promise<(), Error> {
-        unimplemented!()
+    fn set_pipeline(&mut self, pipeline: Box<dyn PipelineHook>) {
+        todo!()
+    }
+
+    fn on_tail_call(&mut self) -> Promise<any_pointer::Pipeline, crate::Error> {
+        todo!()
+    }
+
+    fn tail_call(self: Box<Self>, request: Box<dyn RequestHook>) -> Promise<(), Error> {
+        let (promise, pipeline) = self.direct_tail_call(request);
+        // TODO somehow send pipeline to tail_call_pipeline_fulfiller
+        promise
     }
 
     fn direct_tail_call(
diff --git a/capnp/src/capability.rs b/capnp/src/capability.rs
index b692b76d4..945182d95 100644
--- a/capnp/src/capability.rs
+++ b/capnp/src/capability.rs
@@ -247,7 +247,7 @@ pub struct Results<T> {
 #[cfg(feature = "alloc")]
 impl<T> Results<T>
 where
-    T: Owned,
+    T: Owned + Pipelined,
 {
     pub fn new(hook: alloc::boxed::Box<dyn ResultsHook>) -> Self {
         Self {
@@ -263,6 +263,15 @@ where
     pub fn set(&mut self, other: T::Reader<'_>) -> crate::Result<()> {
         self.hook.get().unwrap().set_as(other)
     }
+
+    pub fn set_pipeline(&mut self, pipeline: T::Pipeline) {
+        // How do we get a PipelineHook out of `pipeline`?
+        //self.hook.set_pipeline(pipeline)
+    }
+
+    pub fn tail_call<SubParams>(self, tail_request: Request<SubParams, T>) -> Promise<(), Error> {
+        self.hook.tail_call(tail_request.hook)
+    }
 }
 
 pub trait FromTypelessPipeline {
diff --git a/capnp/src/private/capability.rs b/capnp/src/private/capability.rs
index f5f393e7e..4f5a80969 100644
--- a/capnp/src/private/capability.rs
+++ b/capnp/src/private/capability.rs
@@ -93,10 +93,16 @@ impl Clone for alloc::boxed::Box<dyn ClientHook> {
 pub trait ResultsHook {
     fn get(&mut self) -> crate::Result<any_pointer::Builder<'_>>;
     fn allow_cancellation(&self);
+
     fn tail_call(
         self: alloc::boxed::Box<Self>,
         request: alloc::boxed::Box<dyn RequestHook>,
     ) -> Promise<(), crate::Error>;
+
+    fn set_pipeline(&mut self, pipeline: Box<dyn PipelineHook>);
+
+    fn on_tail_call(&mut self) -> Promise<any_pointer::Pipeline, crate::Error>;
+
     fn direct_tail_call(
         self: alloc::boxed::Box<Self>,
         request: alloc::boxed::Box<dyn RequestHook>,