diff --git a/pkg/rtc/participant_signal.go b/pkg/rtc/participant_signal.go
index 315fbfe99..2f23a6860 100644
--- a/pkg/rtc/participant_signal.go
+++ b/pkg/rtc/participant_signal.go
@@ -444,6 +444,10 @@ func (p *ParticipantImpl) SendDataTrackSubscriberHandles(handles map[uint32]*liv
 	}))
 }
 
+func (p *ParticipantImpl) sendDataTrackDemandUpdate(dataTrackDemandUpdate *livekit.DataTrackDemandUpdate) error {
+	return p.signaller.WriteMessage(p.signalling.SignalDataTrackDemandUpdate(dataTrackDemandUpdate))
+}
+
 func (p *ParticipantImpl) sendStoreDataBlobResponse(requestId uint32, key *livekit.DataBlobKey) error {
 	return p.signaller.WriteMessage(p.signalling.SignalStoreDataBlobResponse(&livekit.StoreDataBlobResponse{
 		RequestId: requestId,
diff --git a/pkg/rtc/signalling/interfaces.go b/pkg/rtc/signalling/interfaces.go
index 2f8f59138..035e54b37 100644
--- a/pkg/rtc/signalling/interfaces.go
+++ b/pkg/rtc/signalling/interfaces.go
@@ -69,6 +69,7 @@ type ParticipantSignalling interface {
 	SignalPublishDataTrackResponse(publishDataTrackResponse *livekit.PublishDataTrackResponse) proto.Message
 	SignalUnpublishDataTrackResponse(unpublishDataTrackResponse *livekit.UnpublishDataTrackResponse) proto.Message
 	SignalDataTrackSubscriberHandles(dataTrackSubscriberHandles *livekit.DataTrackSubscriberHandles) proto.Message
+	SignalDataTrackDemandUpdate(dataTrackDemandUpdate *livekit.DataTrackDemandUpdate) proto.Message
 	SignalStoreDataBlobResponse(storeDataBlobResponse *livekit.StoreDataBlobResponse) proto.Message
 	SignalGetDataBlobResponse(getDataBlobResponse *livekit.GetDataBlobResponse) proto.Message
 }
diff --git a/pkg/rtc/signalling/signalling.go b/pkg/rtc/signalling/signalling.go
index c13cee1be..fe0107d5b 100644
--- a/pkg/rtc/signalling/signalling.go
+++ b/pkg/rtc/signalling/signalling.go
@@ -259,6 +259,14 @@ func (s *signalling) SignalDataTrackSubscriberHandles(dataTrackSubscriberHandles
 	}
 }
 
+func (s *signalling) SignalDataTrackDemandUpdate(dataTrackDemandUpdate *livekit.DataTrackDemandUpdate) proto.Message {
+	return &livekit.SignalResponse{
+		Message: &livekit.SignalResponse_DataTrackDemandUpdate{
+			DataTrackDemandUpdate: dataTrackDemandUpdate,
+		},
+	}
+}
+
 func (s *signalling) SignalStoreDataBlobResponse(storeDataBlobResponse *livekit.StoreDataBlobResponse) proto.Message {
 	return &livekit.SignalResponse{
 		Message: &livekit.SignalResponse_StoreDataBlobResponse{
diff --git a/pkg/rtc/signalling/signallingunimplemented.go b/pkg/rtc/signalling/signallingunimplemented.go
index 8210c6aac..36ad12791 100644
--- a/pkg/rtc/signalling/signallingunimplemented.go
+++ b/pkg/rtc/signalling/signallingunimplemented.go
@@ -128,6 +128,10 @@ func (u *signallingUnimplemented) SignalDataTrackSubscriberHandles(dataTrackSubs
 	return nil
 }
 
+func (u *signallingUnimplemented) SignalDataTrackDemandUpdate(dataTrackDemandUpdate *livekit.DataTrackDemandUpdate) proto.Message {
+	return nil
+}
+
 func (u *signallingUnimplemented) SignalStoreDataBlobResponse(storeDataBlobResponse *livekit.StoreDataBlobResponse) proto.Message {
 	return nil
 }