Remove unused Err attribute on database subscription

This commit is contained in:
Daniel 2020-03-20 17:22:38 +01:00
parent 3bdca53c14
commit be456c9d64
2 changed files with 2 additions and 3 deletions

View file

@ -384,9 +384,9 @@ func (api *DatabaseAPI) processSub(opID []byte, sub *database.Subscription) {
default: default:
api.send(opID, dbMsgTypeUpd, r.Key(), data) api.send(opID, dbMsgTypeUpd, r.Key(), data)
} }
} else if sub.Err != nil { } else {
// sub feed ended // sub feed ended
api.send(opID, dbMsgTypeError, sub.Err.Error(), nil) api.send(opID, dbMsgTypeDone, "", nil)
} }
} }
} }

View file

@ -13,7 +13,6 @@ type Subscription struct {
canceled bool canceled bool
Feed chan record.Record Feed chan record.Record
Err error
} }
// Cancel cancels the subscription. // Cancel cancels the subscription.