aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-12-06 16:44:39 +0900
committerOphestra <cat@gensokyo.uk>2025-12-06 16:44:39 +0900
commit2b22efcdf1024bb0002ad648c2ba2c457222f59b (patch)
tree6e42db325499b623398f8516875499d85d53a47e
parent8a2f9edcf963358aeeddf1ee544300e2ec72a533 (diff)
internal/pipewire: rename context consume method
This name is more correct since it does not roundtrip, but receives messages. This is also more consistent with the method on event proxies. Signed-off-by: Ophestra <cat@gensokyo.uk>
-rw-r--r--internal/pipewire/pipewire.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/pipewire/pipewire.go b/internal/pipewire/pipewire.go
index 82301d02..d0f1e7a6 100644
--- a/internal/pipewire/pipewire.go
+++ b/internal/pipewire/pipewire.go
@@ -536,7 +536,7 @@ func (ctx *Context) Roundtrip() (err error) {
var remaining []byte
for {
- remaining, err = ctx.roundtrip(remaining)
+ remaining, err = ctx.consume(remaining)
if err == nil {
continue
}
@@ -554,8 +554,8 @@ func (ctx *Context) Roundtrip() (err error) {
}
}
-// roundtrip receives messages from the server and processes events.
-func (ctx *Context) roundtrip(receiveRemaining []byte) (remaining []byte, err error) {
+// consume receives messages from the server and processes events.
+func (ctx *Context) consume(receiveRemaining []byte) (remaining []byte, err error) {
var (
// this holds onto non-protocol errors encountered during event handling;
// errors that prevent event processing from continuing must be panicked