🚧 Add debug output
This commit is contained in:
parent
09fb2eed85
commit
0a23394b56
1 changed files with 1 additions and 0 deletions
|
@ -4,6 +4,7 @@ import * as stream from 'stream';
|
||||||
function waitReadableLength(inputStream: stream.Readable, minLength: number): Promise<void> {
|
function waitReadableLength(inputStream: stream.Readable, minLength: number): Promise<void> {
|
||||||
return new Promise((resolve) => {
|
return new Promise((resolve) => {
|
||||||
const interval = setInterval(() => {
|
const interval = setInterval(() => {
|
||||||
|
console.log('waiting...', inputStream.readableLength, minLength);
|
||||||
if (inputStream.readableLength >= minLength) {
|
if (inputStream.readableLength >= minLength) {
|
||||||
clearInterval(interval);
|
clearInterval(interval);
|
||||||
resolve();
|
resolve();
|
||||||
|
|
Loading…
Reference in a new issue