chore: test a little bit more (#17)

bustle · Dec 8, 2018 · 94dea18 · 94dea18
1 parent c5acfd6
commit 94dea18
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 19 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -49,7 +49,7 @@
     "eslint-plugin-typescript": "^0.14.0",
     "ioredis": "^4.2.0",
     "jest": "^23.6.0",
-    "streaming-iterables": "^3.0.5",
+    "streaming-iterables": "^3.0.7",
     "ts-jest": "^23.10.5",
     "ts-node": "^7.0.1",
     "tslint": "^5.11.0",

diff --git a/src/redis-loader.test.ts b/src/redis-loader.test.ts
@@ -1,6 +1,6 @@
 import bluebird from 'bluebird'
 import { collect } from 'bluestream'
-import { collect as collectItr } from 'streaming-iterables'
+import { collect as collectItr, flatten } from 'streaming-iterables'
 import redisLoader from '.'
 
 export const keyPrefix = '_test_'
@@ -219,13 +219,14 @@ describe('Redis - Loader', () => {
     it('paginates', async () => {
       const work = []
       for (let i = 0; i < 500; i++) {
-        redis.zadd('foo', String(i), String(i))
+        redis.zadd('foo', String(i), `member${i}`)
       }
       await Promise.all(work)
       const results = await collectItr(redis.zscanIterable('foo', { count: 10 }))
       const { batchCount } = redis.stats
       expect(results.length).toBeGreaterThan(1)
       expect(batchCount).toBeGreaterThan(1)
+      expect((await collectItr(flatten(results)))).toHaveLength(1000)
     })
   })