Method stream

packages/mongodb/src/MongoDriver.ts:52–87

(
    entityName: EntityName<T>,
    where: FilterQuery<T>,
    options: StreamOptions<T, any, any, any> & { rawResults?: boolean },
  )

  }

  async *stream<T extends object>(
    entityName: EntityName<T>,
    where: FilterQuery<T>,
    options: StreamOptions<T, any, any, any> & { rawResults?: boolean },
  ): AsyncIterableIterator<T> {
    if (this.metadata.find(entityName)?.virtual) {
      yield* this.streamVirtual(entityName, where, options) as any;
      return;
    }

    const fields = this.buildFields(
      entityName,
      (options.populate as unknown as PopulateOptions<T>[]) || [],
      options.fields,
      options.exclude as any,
    );
    where = this.renameFields(entityName, where as T, true);
    const orderBy = Utils.asArray(options.orderBy).map(orderBy => this.renameFields(entityName, orderBy as T, true));
    const res = this.getConnection('read').stream(entityName, where, {
      orderBy,
      limit: options.limit,
      offset: options.offset,
      fields,
      ctx: options.ctx,
      chunkSize: options.chunkSize ?? 100,
      ...this.buildQueryOptions(options),
    });

    for await (const item of res) {
      if (options.rawResults) {
        yield item as any;
      } else {
        yield this.mapResult(item, this.metadata.find(entityName)) as T;
      }
    }
  }

  async find<T extends object, P extends string = never, F extends string = never, E extends string = never>(
    entityName: EntityName<T>,