fix: trancode dispose will block

This commit is contained in:
langhuihui
2024-11-10 09:11:51 +08:00
parent 142a1f5869
commit 07566e4780
4 changed files with 24 additions and 9 deletions

View File

@@ -166,7 +166,7 @@ func (t *Transformer) Start() (err error) {
return t.ffmpeg.Start()
}
func (t *Transformer) Run() error {
func (t *Transformer) Go() error {
t.SetDescription("pid", t.ffmpeg.Process.Pid)
if t.From.Mode == "pipe" {
rBuf := make(chan []byte, 100)