diff options
| author | Ophestra <cat@gensokyo.uk> | 2025-12-06 21:09:55 +0900 |
|---|---|---|
| committer | Ophestra <cat@gensokyo.uk> | 2025-12-06 21:09:55 +0900 |
| commit | bb1fc4c7bcd9730b774f2afb079b814c928c0b5a (patch) | |
| tree | 0400e5461a27233608d97a2b45ff2662b88cc17e /internal/pipewire/pipewire.go | |
| parent | f44923da296720360e359016ac83c6a56deeb0f1 (diff) | |
internal/pipewire: check pending ids after done
This is not guaranteed to have completed after a roundtrip. This is leftover from when Roundtrip also sent and waited for sync.
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'internal/pipewire/pipewire.go')
| -rw-r--r-- | internal/pipewire/pipewire.go | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/internal/pipewire/pipewire.go b/internal/pipewire/pipewire.go index 06f7fc6a..907f8543 100644 --- a/internal/pipewire/pipewire.go +++ b/internal/pipewire/pipewire.go @@ -18,7 +18,6 @@ import ( "encoding/binary" "fmt" "io" - "maps" "os" "runtime" "slices" @@ -601,13 +600,6 @@ func (ctx *Context) roundtrip() (err error) { err = &ProxyFatalError{Err: danglingFiles, ProxyErrs: ctx.cloneAsProxyErrors()} return } - - // this check must happen after everything else passes - if len(ctx.pendingIds) != 0 { - ctx.closeReceivedFiles() - err = &ProxyFatalError{Err: UnacknowledgedProxyError(slices.Collect(maps.Keys(ctx.pendingIds))), ProxyErrs: ctx.cloneAsProxyErrors()} - return - } }() var remaining []byte |