diff --git a/src/gateware/cxp.py b/src/gateware/cxp.py
index fa324e5..5adf5cd 100644
--- a/src/gateware/cxp.py
+++ b/src/gateware/cxp.py
@@ -30,8 +30,11 @@ class DownConn_Interface(Module, AutoCSR):
         self.submodules.conv = conv = stream.StrideConverter(upconn_layout, downconn_layout, reverse=True)
         self.submodules.debug_out = debug_out = RX_Debug_Buffer()
 
-        rx_pipeline = [debug_src, conv, debug_out]
+        tx_pipeline = [debug_src, conv, phy.sinks[0]]
+        for s, d in zip(tx_pipeline, tx_pipeline[1:]):
+            self.comb += s.source.connect(d.sink)
 
+        rx_pipeline = [phy.sources[0], debug_out]
         for s, d in zip(rx_pipeline, rx_pipeline[1:]):
             self.comb += s.source.connect(d.sink)