diff --git a/db/blip_handler.go b/db/blip_handler.go index 5ffc6595e4..2de9aff356 100644 --- a/db/blip_handler.go +++ b/db/blip_handler.go @@ -629,7 +629,7 @@ func (bh *blipHandler) sendBatchOfChanges(sender *blip.Sender, changeArray [][]a bh.replicationStats.SendChangesCount.Add(int64(len(changeArray))) // Spawn a goroutine to await the client's response: go func(bh *blipHandler, sender *blip.Sender, response *blip.Message, changeArray [][]any, sendTime time.Time, dbCollection *DatabaseCollectionWithUser) { - if err := bh.handleChangesResponse(bh.loggingCtx, sender, response, changeArray, sendTime, dbCollection, bh.collectionIdx); err != nil { + if err := bh.handleChangesResponse(bh.loggingCtx, sender, response, changeArray, sendTime, dbCollection, bh.collectionIdx); err != nil && !errors.Is(err, ErrClosedBLIPSender) { base.WarnfCtx(bh.loggingCtx, "Error from bh.handleChangesResponse: %v", err) if bh.fatalErrorCallback != nil { bh.fatalErrorCallback(err)