1 | import { Action } from '@ngrx/store';
|
2 | import { Observable, OperatorFunction } from 'rxjs';
|
3 |
|
4 | export interface ActConfig<Input, OutputAction extends Action, ErrorAction extends Action, CompleteAction extends Action, UnsubscribeAction extends Action> {
|
5 | project: (input: Input, index: number) => Observable<OutputAction>;
|
6 | error: (error: any, input: Input) => ErrorAction;
|
7 | complete?: (count: number, input: Input) => CompleteAction;
|
8 | operator?: <Input, OutputAction>(project: (input: Input, index: number) => Observable<OutputAction>) => OperatorFunction<Input, OutputAction>;
|
9 | unsubscribe?: (count: number, input: Input) => UnsubscribeAction;
|
10 | }
|
11 |
|
12 |
|
13 |
|
14 |
|
15 | export declare function act<Input, OutputAction extends Action, ErrorAction extends Action>(project: (input: Input, index: number) => Observable<OutputAction>, error: (error: any, input: Input) => ErrorAction): (source: Observable<Input>) => Observable<OutputAction | ErrorAction>;
|
16 |
|
17 |
|
18 |
|
19 |
|
20 | export declare function act<Input, OutputAction extends Action, ErrorAction extends Action, CompleteAction extends Action = never, UnsubscribeAction extends Action = never>(config: ActConfig<Input, OutputAction, ErrorAction, CompleteAction, UnsubscribeAction>): (source: Observable<Input>) => Observable<OutputAction | ErrorAction | CompleteAction | UnsubscribeAction>;
|