Skip to content

Commit

Permalink
Simplify stream cleanup in composedStream test
Browse files Browse the repository at this point in the history
Replaced Promise.allSettled with a for-loop for stream destruction in the composedStream integration test. This change ensures that each stream is destroyed sequentially.
  • Loading branch information
outerlook committed Oct 23, 2024
1 parent ddb2442 commit 30aa280
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions tests/integration/composedStream.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -134,11 +134,9 @@ describe.sequential(
expect(firstRecord!.dateValue).toBe("2020-01-01");
} finally {
// Cleanup: destroy all streams
await Promise.allSettled(
allStreamIds.map((streamId) =>
defaultClient.destroyStream(streamId, true).catch(() => {}),
),
);
for (const streamId of allStreamIds) {
await defaultClient.destroyStream(streamId, true).catch(() => {});
}
}
},
);
Expand Down

0 comments on commit 30aa280

Please sign in to comment.