import { httpResponse } from '..';

/**
 *
 * @param {DataStream} readable - JSON stream
 * @param {Object} spec - JSON aggregation spec
 * @returns {Promise} with aggregation result
 * @example
 * Spec JSON example:
 * {
 *      "$max": {$field: "open", $label: "Open"},
        "$group": {
            "$field": "Ticker",
            $label: "Symbol",
            "$max": "high",
            "$min": {$field: "close", $label: "Low"}
        }
    }
 */
export function agg(readable: DataStream, spec: any): Promise<any>;
/**
 * Persistent NoSql and Kev-Value datastore
 */
export type DataStream = {
  /**
   * - Emits data, stream.on('data', (data) => //console.debug(data))
   */
  on: (arg0: string, arg1: (arg0: any) => any) => void;
  /**
   * - Pipe datastream to JSON output
   */
  json: (response: httpResponse) => void;
  /**
   * - Return an array of objects
   */
  toArray: () => Promise<object[]>;
};
//# sourceMappingURL=index.d.mts.map