diff --git a/api/database.go b/api/database.go
index 8f2c4e0..8a365c9 100644
--- a/api/database.go
+++ b/api/database.go
@@ -384,9 +384,9 @@ func (api *DatabaseAPI) processSub(opID []byte, sub *database.Subscription) {
 				default:
 					api.send(opID, dbMsgTypeUpd, r.Key(), data)
 				}
-			} else if sub.Err != nil {
+			} else {
 				// sub feed ended
-				api.send(opID, dbMsgTypeError, sub.Err.Error(), nil)
+				api.send(opID, dbMsgTypeDone, "", nil)
 			}
 		}
 	}
diff --git a/database/subscription.go b/database/subscription.go
index 6d29b7e..ffe516a 100644
--- a/database/subscription.go
+++ b/database/subscription.go
@@ -13,7 +13,6 @@ type Subscription struct {
 	canceled bool
 
 	Feed chan record.Record
-	Err  error
 }
 
 // Cancel cancels the subscription.