retry-request
Advanced tools
Comparing version 1.3.0 to 1.3.1
11
index.js
'use strict'; | ||
var request = require('request'); | ||
var StreamCache = require('stream-cache'); | ||
var through = require('through2'); | ||
@@ -43,3 +42,3 @@ | ||
var requestStream; | ||
var cacheStream; | ||
var delayStream; | ||
@@ -69,3 +68,3 @@ var activeRequest; | ||
function resetStreams() { | ||
cacheStream = null; | ||
delayStream = null; | ||
@@ -82,3 +81,3 @@ if (requestStream) { | ||
if (streamMode) { | ||
cacheStream = new StreamCache(); | ||
delayStream = through({ objectMode: opts.objectMode }); | ||
requestStream = opts.request(requestOpts); | ||
@@ -90,3 +89,3 @@ | ||
.on('complete', retryStream.emit.bind(retryStream, 'complete')) | ||
.pipe(cacheStream); | ||
.pipe(delayStream); | ||
} else { | ||
@@ -123,3 +122,3 @@ activeRequest = opts.request(requestOpts, onResponse); | ||
retryStream.emit('response', response); | ||
cacheStream.pipe(retryStream); | ||
delayStream.pipe(retryStream); | ||
} else { | ||
@@ -126,0 +125,0 @@ callback(err, response, body); |
{ | ||
"name": "retry-request", | ||
"version": "1.3.0", | ||
"version": "1.3.1", | ||
"description": "Retry a request.", | ||
@@ -22,3 +22,2 @@ "main": "index.js", | ||
"request": "^2.69.0", | ||
"stream-cache": "0.0.2", | ||
"through2": "^2.0.0" | ||
@@ -25,0 +24,0 @@ }, |
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
2
7417
106
- Removedstream-cache@0.0.2
- Removedstream-cache@0.0.2(transitive)