diff --git a/generic/threadshare/src/tcpclientsrc/imp.rs b/generic/threadshare/src/tcpclientsrc/imp.rs
index 513a639c1..dd837eea0 100644
--- a/generic/threadshare/src/tcpclientsrc/imp.rs
+++ b/generic/threadshare/src/tcpclientsrc/imp.rs
@@ -127,7 +127,10 @@ impl PadSrcHandler for TcpClientSrcPadHandler {
         use gst::QueryViewMut;
         let ret = match query.view_mut() {
             QueryViewMut::Latency(q) => {
-                q.set(false, gst::ClockTime::ZERO, gst::ClockTime::NONE);
+                let latency =
+                    gst::ClockTime::try_from(imp.settings.lock().unwrap().context_wait).unwrap();
+                gst::debug!(CAT, obj = pad, "Reporting latency {latency}");
+                q.set(true, latency, gst::ClockTime::NONE);
                 true
             }
             QueryViewMut::Scheduling(q) => {
diff --git a/generic/threadshare/src/udpsrc/imp.rs b/generic/threadshare/src/udpsrc/imp.rs
index 33c277c7e..fec350877 100644
--- a/generic/threadshare/src/udpsrc/imp.rs
+++ b/generic/threadshare/src/udpsrc/imp.rs
@@ -153,7 +153,10 @@ impl PadSrcHandler for UdpSrcPadHandler {
         use gst::QueryViewMut;
         let ret = match query.view_mut() {
             QueryViewMut::Latency(q) => {
-                q.set(true, gst::ClockTime::ZERO, gst::ClockTime::NONE);
+                let latency =
+                    gst::ClockTime::try_from(imp.settings.lock().unwrap().context_wait).unwrap();
+                gst::debug!(CAT, obj = pad, "Reporting latency {latency}");
+                q.set(true, latency, gst::ClockTime::NONE);
                 true
             }
             QueryViewMut::Scheduling(q) => {