pull-to-stream
Advanced tools
Comparing version 0.1.0 to 0.1.1
@@ -1,4 +0,14 @@ | ||
# 0.1.0 (2019-02-22) | ||
## [0.1.1](https://github.com/hugomrdias/pull-to-stream/compare/v0.1.0...v0.1.1) (2019-04-24) | ||
### Bug Fixes | ||
* dont drain source while drain in progress ([72629c9](https://github.com/hugomrdias/pull-to-stream/commit/72629c9)) | ||
* improve drain recursion stop condition ([d28c0b4](https://github.com/hugomrdias/pull-to-stream/commit/d28c0b4)) | ||
# [0.1.0](https://github.com/hugomrdias/pull-to-stream/compare/64761f2...v0.1.0) (2019-02-22) | ||
### Features | ||
@@ -5,0 +15,0 @@ |
@@ -9,2 +9,3 @@ 'use strict'; | ||
this.source = source; | ||
this.drainingSource = false; | ||
this.sink = sink; | ||
@@ -22,2 +23,3 @@ this.input = []; | ||
this.drainingSource = true; | ||
this.source(null, function next(end, data) { | ||
@@ -34,2 +36,4 @@ if (end instanceof Error) { | ||
self.source(null, next); | ||
} else { | ||
self.drainingSource = false; | ||
} | ||
@@ -40,3 +44,3 @@ }); | ||
_read() { | ||
if (this.source) { | ||
if (this.source && !this.drainingSource) { | ||
this.drainPull(); | ||
@@ -43,0 +47,0 @@ } |
{ | ||
"name": "pull-to-stream", | ||
"version": "0.1.0", | ||
"version": "0.1.1", | ||
"description": "pull-stream to stream module ", | ||
@@ -5,0 +5,0 @@ "repository": "hugomrdias/pull-to-stream", |
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
7775
106