Skip to content

Commit aba79d2

Browse files
committed
If nothing to collect then resolve immediately
1 parent d79eac4 commit aba79d2

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/reader.ts

+8
Original file line numberDiff line numberDiff line change
@@ -264,6 +264,10 @@ export class HyperionSequentialReader {
264264
private async collectTraces(actArray: any[], expectedLength: number) {
265265
//console.log(`Waiting for ${expectedLength} traces to be collected...`);
266266
await new Promise<void>((resolve) => {
267+
if (expectedLength === 0) {
268+
resolve();
269+
return;
270+
}
267271
this.traceCollector = (value) => {
268272
actArray.push(value.decodedAct);
269273
if (actArray.length === expectedLength) {
@@ -277,6 +281,10 @@ export class HyperionSequentialReader {
277281

278282
private async collectDeltas(deltaRows: any[], expectedLength: number) {
279283
await new Promise<void>((resolve) => {
284+
if (expectedLength === 0) {
285+
resolve();
286+
return;
287+
}
280288
this.deltaCollector = (value) => {
281289
deltaRows.push(value.decodedDeltaRow);
282290
if (deltaRows.length === expectedLength) {

0 commit comments

Comments
 (0)