stanchionjs
Advanced tools
Comparing version 1.0.0 to 1.1.0
@@ -16,3 +16,2 @@ "use strict"; | ||
concurrency: 10, | ||
prefetchRatio: 1.2, | ||
redisKey: 'stanchion:queue', | ||
@@ -144,3 +143,3 @@ retryAttempts: 6, | ||
return rxjs_1.Observable.create((observer) => { | ||
let tickets = Math.ceil(self.options.concurrency * self.options.prefetchRatio); | ||
let tickets = self.options.concurrency; | ||
const buffer$ = new rxjs_1.Subject(); | ||
@@ -147,0 +146,0 @@ const done$ = new rxjs_1.Subject(); |
{ | ||
"name": "stanchionjs", | ||
"version": "1.0.0", | ||
"version": "1.1.0", | ||
"description": "A simple & fast queue done right. backed by Redis, supports auto-reconnect, TypeScript, Promise and Rxjs.", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
@@ -228,9 +228,10 @@ <h1 align=center> | ||
}, | ||
// If you have lots of I/O intensive job, increase this may help. | ||
// If you have lots of I/O intensive jobs, increase this may help. | ||
concurrency: 10, | ||
// `concurrency` * `prefetchRatio` = how many Redis command will be emitted. | ||
prefetchRatio: 1.2, | ||
// Redis key for this queue. | ||
redisKey: 'stanchion:queue', | ||
// How many times you want Stanchion to reconnecting when connection lost. | ||
// How many times you want Stanchion to try reconnecting when connection is lost. | ||
retryAttempts: 6, | ||
@@ -237,0 +238,0 @@ } |
@@ -24,3 +24,2 @@ import { | ||
concurrency: number, | ||
prefetchRatio: number, | ||
redisKey: string, | ||
@@ -27,0 +26,0 @@ retryAttempts: number, |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
338
34110
577