lib/entities-store: support ttl: Infinity

see also #1

lib/entities-store.js

@@ -25,14 +25,16 @@ const encodeField = (fieldNumber, wireType, dataLength) => {
 }
 
 const createEntitiesStore = (ttl, timestamp) => {
+	const useTtl = ttl !== Infinity
+
 	let timers = new Map()
 	let datas = new Map()
 	let fields = new Map()
 	let cache = null // cached final `FeedMessage` buffer
 
 	const del = (id) => {
-		if (!timers.has(id)) return;
-		clearTimeout(timers.get(id))
+		if (!datas.has(id)) return;
+		if (useTtl) clearTimeout(timers.get(id))
 		timers.delete(id)
 		datas.delete(id)
 		fields.delete(id)
@@ -43,10 +45,12 @@ const createEntitiesStore = (ttl, timestamp) => {
 		del(id)
 		cache = null
 
-		// todo: use sth more memory-efficient than closures?
-		timers.set(id, setTimeout(() => {
-			remove(id)
-		}, ttl))
+		if (useTtl) {
+			// todo: use sth more memory-efficient than closures?
+			timers.set(id, setTimeout(() => {
+				remove(id)
+			}, ttl))
+		}
 
 		const data = FeedEntity.encode(entity)
 		datas.set(id, data)
@@ -67,12 +71,12 @@ const createEntitiesStore = (ttl, timestamp) => {
 		cache = null
 	}
 
-	const nrOfEntities = () => timers.size
+	const nrOfEntities = () => datas.size
 
 	const asFeedMessage = () => {
 		if (cache !== null) return cache
 
-		const ids = Array.from(timers.keys())
+		const ids = Array.from(datas.keys())
 		const chunks = new Array(2 + ids.length * 2)
 
 		const header = chunks[1] = FeedHeader.encode({