Method aggregate

packages/mongodb/src/MongoDriver.ts:515–522

(
    entityName: EntityName,
    pipeline: any[],
    ctx?: Transaction<ClientSession>,
    signal?: AbortSignal,
  )

  }

  override async aggregate(
    entityName: EntityName,
    pipeline: any[],
    ctx?: Transaction<ClientSession>,
    signal?: AbortSignal,
  ): Promise<any[]> {
    return this.rethrow(this.getConnection('read').aggregate(entityName, pipeline, ctx, undefined, signal));
  }

  async *streamAggregate<T extends object>(
    entityName: EntityName<T>,