import { Observable } from "rxjs"; import { Collection } from "./Collection"; export interface IActiveQuery extends IBaseQuery { sql: string; execute(): Observable>; } export interface IBaseQuery { select(fields?: string | string[]): IActiveQuery; where(clause: (item: T, binds: B) => boolean, bindObj?: B): IActiveQuery; }