From 1a5289ec65e4588e769edc7becd0bd10b92051de Mon Sep 17 00:00:00 2001 From: TimTIM Date: Tue, 30 Nov 2021 02:20:24 +0800 Subject: [PATCH 1/2] Fix return type of hasNext() --- src/change_stream.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/change_stream.ts b/src/change_stream.ts index 684eec7097..554485e1a0 100644 --- a/src/change_stream.ts +++ b/src/change_stream.ts @@ -310,7 +310,7 @@ export class ChangeStream extends TypedEven } /** Check if there is any document still available in the Change Stream */ - hasNext(callback?: Callback): Promise | void { + hasNext(callback?: Callback): Promise | void { setIsIterator(this); return maybePromise(callback, cb => { getCursor(this, (err, cursor) => { From c728ee74c7f633267fc8fb7d388c44c3b51e60ec Mon Sep 17 00:00:00 2001 From: TimTIM Date: Tue, 30 Nov 2021 04:04:05 +0800 Subject: [PATCH 2/2] Improve hasNext() typing in src/change_stream.ts Co-authored-by: Neal Beeken --- src/change_stream.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/change_stream.ts b/src/change_stream.ts index 554485e1a0..c1d885f65c 100644 --- a/src/change_stream.ts +++ b/src/change_stream.ts @@ -310,6 +310,8 @@ export class ChangeStream extends TypedEven } /** Check if there is any document still available in the Change Stream */ + hasNext(): Promise; + hasNext(callback: Callback): void; hasNext(callback?: Callback): Promise | void { setIsIterator(this); return maybePromise(callback, cb => {