We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d3f2674 commit 4b50596Copy full SHA for 4b50596
src/cmap/wire_protocol/on_data.ts
@@ -49,7 +49,7 @@ export function onData(
49
/** Set to true only after event listeners have been removed. */
50
let finished = false;
51
52
- const iterator: AsyncGenerator<Buffer> = {
+ const iterator: AsyncGenerator<Buffer> & AsyncDisposable = {
53
next() {
54
// First, we consume all unread events
55
const value = unconsumedEvents.shift();
@@ -87,6 +87,10 @@ export function onData(
87
88
[Symbol.asyncIterator]() {
89
return this;
90
+ },
91
+
92
+ async [Symbol.asyncDispose]() {
93
+ await closeHandler();
94
}
95
};
96
0 commit comments