diff --git a/src/mongo_logger.ts b/src/mongo_logger.ts index 23f270bd4a3..f645cf9afb7 100644 --- a/src/mongo_logger.ts +++ b/src/mongo_logger.ts @@ -1,5 +1,5 @@ import type { Writable } from 'stream'; -import { inspect } from 'util'; +import { inspect, promisify } from 'util'; import { type Document, EJSON, type EJSONOptions, type ObjectId } from './bson'; import type { CommandStartedEvent } from './cmap/command_monitoring_events'; @@ -217,10 +217,10 @@ export function createStdioLogger(stream: { write: NodeJS.WriteStream['write']; }): MongoDBLogWritable { return { - write: (log: Log): unknown => { - stream.write(inspect(log, { compact: true, breakLength: Infinity }), 'utf-8'); + write: promisify((log: Log, cb: () => void): unknown => { + stream.write(inspect(log, { compact: true, breakLength: Infinity }), 'utf-8', cb); return; - } + }) }; } @@ -281,7 +281,7 @@ export interface Log extends Record { /** @internal */ export interface MongoDBLogWritable { - write(log: Log): void; + write(log: Log): PromiseLike | any; } function compareSeverity(s0: SeverityLevel, s1: SeverityLevel): 1 | 0 | -1 {