aboutsummaryrefslogtreecommitdiffhomepage
path: root/internal/pipewire/core.go
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-12-11 04:22:03 +0900
committerOphestra <cat@gensokyo.uk>2025-12-11 04:22:03 +0900
commite60ff660f69ee4161ee63af3147b5a77d4139e76 (patch)
treeda0d24eb3782859234e6ec91ff20eef71d0f0722 /internal/pipewire/core.go
parent47db461546f355b971c3ca35d4dec48778c172ab (diff)
internal/pipewire: treat unknown opcode as fatal
Skipping events can cause local state to diverge from the server. Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/pipewire/core.go')
-rw-r--r--internal/pipewire/core.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/pipewire/core.go b/internal/pipewire/core.go
index d115da33..f6199c44 100644
--- a/internal/pipewire/core.go
+++ b/internal/pipewire/core.go
@@ -764,7 +764,7 @@ func (core *Core) consume(opcode byte, files []int, unmarshal func(v any)) error
return proxy.setBoundProps(&boundProps)
default:
- return &UnsupportedOpcodeError{opcode, core.String()}
+ panic(&UnsupportedOpcodeError{opcode, core.String()})
}
}
@@ -831,7 +831,7 @@ func (registry *Registry) consume(opcode byte, files []int, unmarshal func(v any
return nil
default:
- return &UnsupportedOpcodeError{opcode, registry.String()}
+ panic(&UnsupportedOpcodeError{opcode, registry.String()})
}
}