Skip to content

Commit 6e357c1

Browse files
committed
Add server.unref to deal with diff versions of Node and http connections
1 parent 3536e72 commit 6e357c1

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

src/integration/data/vectors/upsertAndUpdate.test.ts

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,12 @@ describe('Testing retry logic via a mock, in-memory http server', () => {
125125
}
126126
});
127127
server.listen(4000); // Host server on local port 4000
128+
server.unref(); // Allow the server to close even if there are open connections
129+
130+
// Error handler
131+
server.on('error', (error) => {
132+
console.error('Server error:', error);
133+
});
128134
};
129135

130136
beforeEach(() => {
@@ -133,8 +139,14 @@ describe('Testing retry logic via a mock, in-memory http server', () => {
133139

134140
afterEach(async () => {
135141
// Close server and reset mocks
136-
await new Promise<void>((resolve) => server.close(() => resolve()));
137-
jest.clearAllMocks();
142+
// await new Promise<void>((resolve) => server.close(() => resolve()));
143+
return new Promise<void>((resolve) => {
144+
server.close(() => {
145+
jest.clearAllMocks();
146+
server.unref();
147+
resolve();
148+
});
149+
});
138150
});
139151

140152
test('Upsert operation should retry 1x if server responds 1x with error and 1x with success', async () => {

0 commit comments

Comments
 (0)