diff --git a/daemon/call.c b/daemon/call.c
index d4b7e65b2..68b933adc 100644
--- a/daemon/call.c
+++ b/daemon/call.c
@@ -1056,7 +1056,7 @@ void call_media_state_machine(struct call_media *m) {
 		call_stream_state_machine(l->data);
 }
 
-static int __init_stream(struct packet_stream *ps) {
+int __init_stream(struct packet_stream *ps) {
 	struct call_media *media = ps->media;
 	struct call *call = ps->call;
 	int dtls_active = -1;
diff --git a/daemon/redis.c b/daemon/redis.c
index f0e35f414..4c7177435 100644
--- a/daemon/redis.c
+++ b/daemon/redis.c
@@ -1440,6 +1440,8 @@ static int json_link_streams(struct call *c, struct redis_list *streams,
 
 		if (ps->media)
 			__rtp_stats_update(ps->rtp_stats, ps->media->codecs_recv);
+
+		__init_stream(ps);
 	}
 
 	return 0;
diff --git a/include/call.h b/include/call.h
index 23ec07dd8..01cfc0da0 100644
--- a/include/call.h
+++ b/include/call.h
@@ -452,6 +452,7 @@ void add_total_calls_duration_in_interval(struct timeval *interval_tv);
 
 void payload_type_free(struct rtp_payload_type *p);
 void __rtp_stats_update(GHashTable *dst, GHashTable *src);
+int __init_stream(struct packet_stream *ps);
 
 const struct rtp_payload_type *__rtp_stats_codec(struct call_media *m);