diff --git a/src/modules/module-echo-cancel.c b/src/modules/module-echo-cancel.c
index 3be731e03..374237c29 100644
--- a/src/modules/module-echo-cancel.c
+++ b/src/modules/module-echo-cancel.c
@@ -202,10 +202,40 @@ static void capture_process(void *d)
 		process(impl);
 }
 
+static void input_param_latency_changed(struct impl *impl, const struct spa_pod *param)
+{
+	struct spa_latency_info latency;
+	uint8_t buffer[1024];
+	struct spa_pod_builder b;
+	const struct spa_pod *params[1];
+
+	if (spa_latency_parse(param, &latency) < 0)
+		return;
+
+	spa_pod_builder_init(&b, buffer, sizeof(buffer));
+	params[0] = spa_latency_build(&b, SPA_PARAM_Latency, &latency);
+
+	if (latency.direction == SPA_DIRECTION_INPUT)
+		pw_stream_update_params(impl->source, params, 1);
+	else
+		pw_stream_update_params(impl->capture, params, 1);
+}
+
+static void input_param_changed(void *data, uint32_t id, const struct spa_pod *param)
+{
+	struct impl *impl = data;
+	switch (id) {
+	case SPA_PARAM_Latency:
+		input_param_latency_changed(impl, param);
+		break;
+	}
+}
+
 static const struct pw_stream_events capture_events = {
 	PW_VERSION_STREAM_EVENTS,
 	.destroy = capture_destroy,
-	.process = capture_process
+	.process = capture_process,
+	.param_changed = input_param_changed
 };
 
 static void source_destroy(void *d)
@@ -218,8 +248,38 @@ static void source_destroy(void *d)
 static const struct pw_stream_events source_events = {
 	PW_VERSION_STREAM_EVENTS,
 	.destroy = source_destroy,
+	.param_changed = input_param_changed
 };
 
+static void output_param_latency_changed(struct impl *impl, const struct spa_pod *param)
+{
+	struct spa_latency_info latency;
+	uint8_t buffer[1024];
+	struct spa_pod_builder b;
+	const struct spa_pod *params[1];
+
+	if (spa_latency_parse(param, &latency) < 0)
+		return;
+
+	spa_pod_builder_init(&b, buffer, sizeof(buffer));
+	params[0] = spa_latency_build(&b, SPA_PARAM_Latency, &latency);
+
+	if (latency.direction == SPA_DIRECTION_INPUT)
+		pw_stream_update_params(impl->source, params, 1);
+	else
+		pw_stream_update_params(impl->capture, params, 1);
+}
+
+static void output_param_changed(void *data, uint32_t id, const struct spa_pod *param)
+{
+	struct impl *impl = data;
+	switch (id) {
+	case SPA_PARAM_Latency:
+		output_param_latency_changed(impl, param);
+		break;
+	}
+}
+
 static void sink_destroy(void *d)
 {
 	struct impl *impl = d;
@@ -245,11 +305,13 @@ static void playback_destroy(void *d)
 static const struct pw_stream_events playback_events = {
 	PW_VERSION_STREAM_EVENTS,
 	.destroy = playback_destroy,
+	.param_changed = output_param_changed
 };
 static const struct pw_stream_events sink_events = {
 	PW_VERSION_STREAM_EVENTS,
 	.destroy = sink_destroy,
-	.process = sink_process
+	.process = sink_process,
+	.param_changed = output_param_changed
 };
 
 static int setup_streams(struct impl *impl)
diff --git a/src/modules/module-loopback.c b/src/modules/module-loopback.c
index 21e8fb810..08074721c 100644
--- a/src/modules/module-loopback.c
+++ b/src/modules/module-loopback.c
@@ -162,10 +162,41 @@ static void capture_process(void *d)
 		pw_stream_queue_buffer(impl->playback, out);
 }
 
+static void param_latency_changed(struct impl *impl, const struct spa_pod *param)
+{
+	struct spa_latency_info latency;
+	uint8_t buffer[1024];
+	struct spa_pod_builder b;
+	const struct spa_pod *params[1];
+
+	if (spa_latency_parse(param, &latency) < 0)
+		return;
+
+	spa_pod_builder_init(&b, buffer, sizeof(buffer));
+	params[0] = spa_latency_build(&b, SPA_PARAM_Latency, &latency);
+
+	if (latency.direction == SPA_DIRECTION_INPUT)
+		pw_stream_update_params(impl->capture, params, 1);
+	else
+		pw_stream_update_params(impl->playback, params, 1);
+}
+
+static void param_changed(void *data, uint32_t id, const struct spa_pod *param)
+{
+	struct impl *impl = data;
+
+	switch (id) {
+	case SPA_PARAM_Latency:
+		param_latency_changed(impl, param);
+		break;
+	}
+}
+
 static const struct pw_stream_events in_stream_events = {
 	PW_VERSION_STREAM_EVENTS,
 	.destroy = capture_destroy,
-	.process = capture_process
+	.process = capture_process,
+	.param_changed = param_changed,
 };
 
 static void playback_destroy(void *d)
@@ -177,7 +208,8 @@ static void playback_destroy(void *d)
 
 static const struct pw_stream_events out_stream_events = {
 	PW_VERSION_STREAM_EVENTS,
-	.destroy = playback_destroy
+	.destroy = playback_destroy,
+	.param_changed = param_changed,
 };
 
 static int setup_streams(struct impl *impl)