1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
|
package main
import (
"time"
"github.com/akosmarton/papipes"
)
func main() {
source := papipes.Source{
Filename: "/tmp/source.sock",
}
source.SetProperty("device.description", "Virtual Input")
source.Open()
defer source.Close()
sink := papipes.Sink{
Filename: "/tmp/sink.sock",
}
sink.SetProperty("device.description", "Virtual Output")
sink.Open()
defer sink.Close()
p := make([]byte, 0)
source.Write(p)
sink.Read(p)
time.Sleep(time.Second * 10)
}
|