| 362 | } |
| 363 | |
| 364 | map<TIterationCallback extends (doc: DispatchTransform<TOptions['transform'], T>, index: number, cursor: this) => unknown>( |
| 365 | callback: TIterationCallback, |
| 366 | thisArg?: ThisParameterType<TIterationCallback>, |
| 367 | ): ReturnType<TIterationCallback>[] { |
| 368 | const result: ReturnType<TIterationCallback>[] = []; |
| 369 | |
| 370 | this.forEach((doc, i) => { |
| 371 | result.push(callback.call(thisArg, doc, i, this) as ReturnType<TIterationCallback>); |
| 372 | }); |
| 373 | |
| 374 | return result; |
| 375 | } |
| 376 | |
| 377 | observe(options: ObserveOptions<T>) { |
| 378 | return this._observeFromObserveChanges(options); |