import { Observable, OperatorFunction } from "rxjs"; import { Action } from "ts-action"; export declare type ActConfig = { complete?: (count: number, action: InputAction) => CompleteAction; error: (error: any, action: InputAction) => ErrorAction; operator?: (project: (input: I, index: number) => Observable) => OperatorFunction; project: (action: InputAction, index: number) => Observable; unsubscribe?: (count: number, action: InputAction) => UnsubscribeAction; }; export declare function act(project: (action: InputAction, index: number) => Observable, error: (error: any, action: InputAction) => ErrorAction): (source: Observable) => Observable; export declare function act(config: ActConfig): (source: Observable) => Observable;