anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-10 01:51:11 +09:00
Code Activity

Remove close send error

Browse source
This commit is contained in:
mcrakhman 2025-01-17 11:40:48 +01:00
parent 3a6c0c1cae
commit 5ceab3b7cd
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
1 changed files with 0 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
commonspace/spacestorage/migration/executor.go
View file

@ -4,7 +4,6 @@ import (
"context" "context"
"github.com/cheggaaa/mb/v3" "github.com/cheggaaa/mb/v3"
"go.uber.org/zap"
"github.com/anyproto/any-sync/app/logger" "github.com/anyproto/any-sync/app/logger"
) )
@ -55,7 +54,6 @@ func (mp *migratePool) sendLoop() {
for { for {
f, err := mp.batch.WaitOne(mp.ctx) f, err := mp.batch.WaitOne(mp.ctx)
if err != nil { if err != nil {
log.Debug("close send loop", zap.Error(err))
return return
} }
f() f()