ldiamond/strom
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Cleanup console logs

Browse Source
This commit is contained in:
Jerry Kurian 2019-09-12 15:35:59 -04:00
parent 48a231d61c
commit 158475183a
2 changed files with 2 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/functions/demux.ts
View File

@ -58,21 +58,7 @@ class Demux extends Writable {
this.streamsByKey[destKey] = this.construct(destKey); this.streamsByKey[destKey] = this.construct(destKey);
} }
if (!this.streamsByKey[destKey].write(chunk, encoding)) { if (!this.streamsByKey[destKey].write(chunk, encoding)) {
console.log(
"waiting drain",
chunk,
this._writableState.length,
this.streamsByKey[destKey]._writableState.length,
this.streamsByKey[destKey]._readableState.length,
);
this.streamsByKey[destKey].once("drain", () => { this.streamsByKey[destKey].once("drain", () => {
console.log(
"calling cb after drain",
chunk,
this._writableState.length,
this.streamsByKey[destKey]._writableState.length,
this.streamsByKey[destKey]._readableState.length,
);
cb(); cb();
}); });
} else { } else {

13
tests/demux.spec.ts
View File

@ -379,7 +379,6 @@ test.cb.only(
const construct = (destKey: string) => { const construct = (destKey: string) => {
const first = map( const first = map(
(chunk: Chunk) => { (chunk: Chunk) => {
console.log("1: ", chunk);
chunk.mapped.push(1); chunk.mapped.push(1);
return chunk; return chunk;
}, },
@ -388,9 +387,7 @@ test.cb.only(
const second = map( const second = map(
async (chunk: Chunk) => { async (chunk: Chunk) => {
console.log("2: ", chunk);
await sleep(slowProcessorSpeed); await sleep(slowProcessorSpeed);
console.log("2 done ", chunk);
chunk.mapped.push(2); chunk.mapped.push(2);
return chunk; return chunk;
}, },
@ -411,7 +408,6 @@ test.cb.only(
// This event should be received after at least 5 * slowProcessorSpeed (two are read immediately by first and second, 5 remaining in demux before drain event) // This event should be received after at least 5 * slowProcessorSpeed (two are read immediately by first and second, 5 remaining in demux before drain event)
_demux.on("drain", () => { _demux.on("drain", () => {
expect(_demux._writableState.length).to.be.equal(0); expect(_demux._writableState.length).to.be.equal(0);
console.log(performance.now() - start);
expect(performance.now() - start).to.be.greaterThan( expect(performance.now() - start).to.be.greaterThan(
slowProcessorSpeed * (input.length - 2), slowProcessorSpeed * (input.length - 2),
); );
@ -431,7 +427,7 @@ test.cb.only(
const start = performance.now(); const start = performance.now();
input.forEach(item => { input.forEach(item => {
console.log(_demux.write(item)); _demux.write(item);
}); });
}, },
); );
@ -461,7 +457,6 @@ test.cb(
const construct = (destKey: string) => { const construct = (destKey: string) => {
const first = map( const first = map(
(chunk: Chunk) => { (chunk: Chunk) => {
console.log("1: ", chunk);
chunk.mapped.push(1); chunk.mapped.push(1);
return chunk; return chunk;
}, },
@ -469,7 +464,6 @@ test.cb(
); );
const second = map( const second = map(
(chunk: Chunk) => { (chunk: Chunk) => {
console.log("2: ", chunk);
chunk.mapped.push(2); chunk.mapped.push(2);
return chunk; return chunk;
}, },
@ -478,9 +472,7 @@ test.cb(
const third = map( const third = map(
async (chunk: Chunk) => { async (chunk: Chunk) => {
console.log("3: ", chunk);
await sleep(slowProcessorSpeed); await sleep(slowProcessorSpeed);
console.log(" 3 done ", chunk);
chunk.mapped.push(3); chunk.mapped.push(3);
return chunk; return chunk;
}, },
@ -504,7 +496,6 @@ test.cb(
// This event should be received after at least 3 * slowProcessorSpeed (two are read immediately by first and second, 3 remaining in demux before drain event) // This event should be received after at least 3 * slowProcessorSpeed (two are read immediately by first and second, 3 remaining in demux before drain event)
_demux.on("drain", () => { _demux.on("drain", () => {
expect(_demux._writableState.length).to.be.equal(0); expect(_demux._writableState.length).to.be.equal(0);
console.log(performance.now() - start);
expect(performance.now() - start).to.be.greaterThan( expect(performance.now() - start).to.be.greaterThan(
slowProcessorSpeed * (input.length - 4), slowProcessorSpeed * (input.length - 4),
); );
@ -524,7 +515,7 @@ test.cb(
const start = performance.now(); const start = performance.now();
input.forEach(item => { input.forEach(item => {
console.log(_demux.write(item)); _demux.write(item);
}); });
}, },
); );