diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-12-06 16:44:39 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-12-06 16:44:39 +0900 |
| commit | 2b22efcdf1024bb0002ad648c2ba2c457222f59b (patch) | |
| tree | 6e42db325499b623398f8516875499d85d53a47e /internal/pipewire | |
| parent | 8a2f9edcf963358aeeddf1ee544300e2ec72a533 (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>
Diffstat (limited to 'internal/pipewire')
| -rw-r--r-- | internal/pipewire/pipewire.go | 6 |
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 |