From a943e3315f05143cebb36b5b23673c7e83837e23 Mon Sep 17 00:00:00 2001
From: Daniel <dhaavi@users.noreply.github.com>
Date: Fri, 11 Jan 2019 22:18:46 +0100
Subject: [PATCH] Fix minor issue in database api

---
 api/database.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/api/database.go b/api/database.go
index 48b9e35..862feb4 100644
--- a/api/database.go
+++ b/api/database.go
@@ -329,9 +329,10 @@ func (api *DatabaseAPI) processSub(opID []byte, sub *database.Subscription) {
 		r.Unlock()
 		if err != nil {
 			api.send(opID, dbMsgTypeWarning, err.Error(), nil)
+			continue
 		}
 		// TODO: use upd, new and delete msgTypes
-		if r.Meta().Deleted > 0 {
+		if r.Meta().IsDeleted() {
 			api.send(opID, dbMsgTypeDel, r.Key(), nil)
 		} else {
 			api.send(opID, dbMsgTypeUpd, r.Key(), data)