diff --git a/internal/core/path.go b/internal/core/path.go index acbf0be1..58981424 100644 --- a/internal/core/path.go +++ b/internal/core/path.go @@ -844,6 +844,8 @@ func (pa *path) handlePublisherRecord(req pathPublisherRecordReq) { pa.onDemandPublisherReadyTimer.Stop() pa.onDemandPublisherReadyTimer = newEmptyTimer() + pa.onDemandPublisherScheduleClose() + for _, req := range pa.describeRequestsOnHold { req.res <- pathDescribeRes{ stream: pa.stream, @@ -855,8 +857,6 @@ func (pa *path) handlePublisherRecord(req pathPublisherRecordReq) { pa.handleReaderSetupPlayPost(req) } pa.setupPlayRequestsOnHold = nil - - pa.onDemandPublisherScheduleClose() } req.res <- pathPublisherRecordRes{stream: pa.stream}