chan directions
This commit is contained in:
parent
1191484efa
commit
3879f1c41b
2 changed files with 2 additions and 2 deletions
|
@ -9,7 +9,7 @@ import (
|
|||
"time"
|
||||
)
|
||||
|
||||
func outUI(output chan liquidsoap.Output) {
|
||||
func outUI(output <-chan liquidsoap.Output) {
|
||||
for msg := range output {
|
||||
if msg.Level <= 2 {
|
||||
fmt.Println(msg)
|
||||
|
|
|
@ -26,7 +26,7 @@ func (e *End) Success() bool {
|
|||
//
|
||||
// RunLiquidsoap is an async function, which provides channels as feedback and needs a channel to ask for its
|
||||
// termination
|
||||
func RunLiquidsoap(configfile string, kill <-chan struct{}) (chan Output, chan End, error) {
|
||||
func RunLiquidsoap(configfile string, kill <-chan struct{}) (<-chan Output, <-chan End, error) {
|
||||
out := make(chan Output)
|
||||
exit := make(chan End, 1)
|
||||
cmd := exec.Command("liquidsoap", "--enable-telnet", configfile)
|
||||
|
|
Loading…
Reference in a new issue