()
| 159 | } |
| 160 | |
| 161 | override async getMore(): Promise<CursorResponse> { |
| 162 | const response = await super.getMore(); |
| 163 | |
| 164 | this.maxWireVersion = maxWireVersion(this.server); |
| 165 | this._processBatch(response); |
| 166 | |
| 167 | this.emit(ChangeStream.MORE, response); |
| 168 | this.emit(ChangeStream.RESPONSE); |
| 169 | return response; |
| 170 | } |
| 171 | } |
nothing calls this directly
no test coverage detected