Skip to content

Commit 461bcde

Browse files
committed
fix: return on reject
1 parent b9c75e2 commit 461bcde

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

src/cmap/wire_protocol/compression.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ const ZSTD_COMPRESSION_LEVEL = 3;
4545
const zlibInflate = (buf: zlib.InputType) => {
4646
return new Promise<Buffer>((resolve, reject) => {
4747
zlib.inflate(buf, (error, result) => {
48-
if (error) reject(error);
48+
if (error) return reject(error);
4949
resolve(result);
5050
});
5151
});
@@ -54,7 +54,7 @@ const zlibInflate = (buf: zlib.InputType) => {
5454
const zlibDeflate = (buf: zlib.InputType, options: zlib.ZlibOptions) => {
5555
return new Promise<Buffer>((resolve, reject) => {
5656
zlib.deflate(buf, options, (error, result) => {
57-
if (error) reject(error);
57+
if (error) return reject(error);
5858
resolve(result);
5959
});
6060
});

src/mongo_logger.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ export function createStdioLogger(stream: {
244244
return new Promise((resolve, reject) => {
245245
const logLine = inspect(log, { compact: true, breakLength: Infinity });
246246
stream.write(`${logLine}\n`, 'utf-8', error => {
247-
if (error) reject(error);
247+
if (error) return reject(error);
248248
resolve(true);
249249
});
250250
});

src/utils.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1238,7 +1238,7 @@ export function squashError(_error: unknown) {
12381238
export const randomBytes = (size: number) => {
12391239
return new Promise<Buffer>((resolve, reject) => {
12401240
crypto.randomBytes(size, (error: Error | null, buf: Buffer) => {
1241-
if (error) reject(error);
1241+
if (error) return reject(error);
12421242
resolve(buf);
12431243
});
12441244
});

0 commit comments

Comments
 (0)