summaryrefslogtreecommitdiff
path: root/soundbox/pipewire_test.go
diff options
context:
space:
mode:
authorxegineering <me@xegineering.eu>2024-11-17 12:51:15 +0100
committerxegineering <me@xegineering.eu>2024-12-08 18:22:10 +0100
commit06c4f8b0120f5598f9d179b8c0fea33df35659a8 (patch)
treecd29e3526c5394cd5daeb8da889c9b56ad2873f3 /soundbox/pipewire_test.go
parent4513eb614707d129824e60270bd45cdee9f04d06 (diff)
downloadsoundbox-go-06c4f8b0120f5598f9d179b8c0fea33df35659a8.tar
soundbox-go-06c4f8b0120f5598f9d179b8c0fea33df35659a8.tar.zst
soundbox-go-06c4f8b0120f5598f9d179b8c0fea33df35659a8.zip
pipewire: Add experimental PipeWire support
This implements a PipeWire capture device which can be used as an input source instead of the already available URL input. Known issues with the current PipeWire support are: - user has to connect the monitor of the default audio sink to the capture device manually - correct shutdown has to be tested - multiple instances do not work - medium code quality requires refactoring Since this is nevertheless usable and possible unknown bugs should be figured out in practise soon this implementation is already added. Bugfixes and refactoring might follow.
Diffstat (limited to 'soundbox/pipewire_test.go')
-rw-r--r--soundbox/pipewire_test.go35
1 files changed, 35 insertions, 0 deletions
diff --git a/soundbox/pipewire_test.go b/soundbox/pipewire_test.go
new file mode 100644
index 0000000..b857414
--- /dev/null
+++ b/soundbox/pipewire_test.go
@@ -0,0 +1,35 @@
+package soundbox_test
+
+import (
+ "context"
+ "log"
+ "net"
+ "time"
+
+ "xengineering.eu/soundbox-go/soundbox"
+)
+
+func ExampleStreamPipewireContext() {
+ ctx, cancel := context.WithCancel(context.Background())
+
+ // all soundboxes are referenced by their MAC address
+ soundboxes := []net.HardwareAddr{
+ {0x00, 0x00, 0x5E, 0x00, 0x53, 0x01},
+ {0x00, 0x00, 0x5E, 0x00, 0x53, 0x02},
+ {0x00, 0x00, 0x5E, 0x00, 0x53, 0x03},
+ }
+
+ // start streaming
+ go func() {
+ err := soundbox.StreamPipewireContext(ctx, soundboxes)
+ if err != nil {
+ log.Fatal(err)
+ }
+ }()
+
+ // let it play for some time
+ time.Sleep(time.Minute)
+
+ // stop it
+ cancel()
+}