import { InferNullable, Observable, ObservableStackItem } from '../types/observable'; import { Store } from '../types/store'; interface Props { onError?: (err: Error, stack?: ObservableStackItem[]) => void; initialValue?: NullableInferredReturnT; singleFlight?: boolean; } type ExecuteReturnType = [NullableInferredT, undefined] | [undefined, Error]; export declare const createCommandStream: (initialise: ({ $, store, }: { $: Observable; store: Store; }) => Observable>, { onError, initialValue, singleFlight, }?: Props>) => { (payload?: InputT): Promise>>; exit$: Observable>; }; export {};