thread-stream
Advanced tools
Comparing version 0.15.0 to 0.15.1
@@ -254,3 +254,3 @@ 'use strict' | ||
if (this[kImpl].destroyed) { | ||
throw new Error('the worker has exited') | ||
return | ||
} | ||
@@ -290,3 +290,3 @@ | ||
if (this[kImpl].destroyed) { | ||
throw new Error('the worker has exited') | ||
return | ||
} | ||
@@ -293,0 +293,0 @@ |
{ | ||
"name": "thread-stream", | ||
"version": "0.15.0", | ||
"version": "0.15.1", | ||
"description": "A streaming way to send data to a Node.js Worker Thread", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -5,3 +5,2 @@ # thread-stream | ||
[![Known Vulnerabilities](https://snyk.io/test/github/pinojs/thread-stream/badge.svg)](https://snyk.io/test/github/pinojs/thread-stream) | ||
[![Coverage Status](https://coveralls.io/repos/github/pinojs/thread-stream/badge.svg?branch=master)](https://coveralls.io/github/pinojs/thread-stream?branch=master) | ||
[![js-standard-style](https://img.shields.io/badge/code%20style-standard-brightgreen.svg?style=flat)](https://standardjs.com/) | ||
@@ -8,0 +7,0 @@ |
@@ -251,3 +251,3 @@ 'use strict' | ||
test('destroy does not error', function (t) { | ||
t.plan(3) | ||
t.plan(5) | ||
@@ -271,3 +271,5 @@ const dest = file() | ||
}) | ||
t.doesNotThrow(() => stream.flushSync()) | ||
t.doesNotThrow(() => stream.end()) | ||
}) | ||
}) |
Sorry, the diff of this file is not supported yet
1640
55384
91