nxshock/promodj
1
0
Fork 0
mirror of https://github.com/nxshock/promodj.git synced 2024-11-27 03:01:01 +05:00
Code Issues Projects Releases Wiki Activity

Log encoder messages

Browse Source
This commit is contained in:
nxshock 2022-02-01 10:02:21 +05:00
parent 65c1ba95c0
commit fbb8c376d4
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
streamer.go
View File

@ -4,11 +4,12 @@ import (
"errors" "errors"
"fmt" "fmt"
"io" "io"
"log"
"net/http" "net/http"
"os/exec" "os/exec"
"gopkg.in/djherbis/buffer.v1"
"github.com/djherbis/nio/v3" "github.com/djherbis/nio/v3"
"gopkg.in/djherbis/buffer.v1"
) )
func stream(url string, w http.ResponseWriter) error { func stream(url string, w http.ResponseWriter) error {
@ -47,7 +48,10 @@ func encode(url string, w io.Writer) error {
} }
go func() { go func() {
cmd.Wait() err := cmd.Wait()
if err != nil {
log.Println(err)
}
}() }()
buf := buffer.New(int64(config.BufferSize) * 1024 * 1024) buf := buffer.New(int64(config.BufferSize) * 1024 * 1024)