diff --git a/api/database.go b/api/database.go
index 8a365c9..39d128b 100644
--- a/api/database.go
+++ b/api/database.go
@@ -387,6 +387,7 @@ func (api *DatabaseAPI) processSub(opID []byte, sub *database.Subscription) {
 			} else {
 				// sub feed ended
 				api.send(opID, dbMsgTypeDone, "", nil)
+				return
 			}
 		}
 	}