import { ComponentType, ReactElement } from "react"; import { EnumeratorLike } from "../collections.js"; import { DispatcherLike, FlowableLike, MulticastObservableLike, ObservableLike, PauseableLike, PauseableObservableLike, StreamOf, StreamableLike } from "../concurrent.js"; import { EventSourceLike } from "../events.js"; import { Factory, Function1, Optional, SideEffect } from "../functions.js"; import { BackpressureStrategy, DisposableLike } from "../utils.js"; interface ReactModule { createComponent(fn: Function1, ObservableLike>, options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): ComponentType; useDispatcher(dispatcher: Optional>): { enqueue: Function1; complete: SideEffect; }; /** */ useDisposable(factory: () => Optional, deps: readonly unknown[]): Optional; /** */ useEnumerator(enumerator: Optional>): { move: Factory; hasCurrent: boolean; current: T; }; /** */ useFlow(flowable: FlowableLike, options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly replay?: number; }): Optional>; useFlow(factory: Factory>, dep: readonly unknown[], options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly replay?: number; }): Optional>; /** */ useListen(eventSource: Optional>): Optional; useListen(factory: Factory>>, deps: readonly unknown[]): Optional; /** */ useObserve(observable: Optional>, options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): Optional; useObserve(factory: Factory>>, deps: readonly unknown[], options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): Optional; /** */ usePauseable(pauseable: Optional): { isPaused: boolean; pause: SideEffect; resume: SideEffect; }; /** */ useStream(streamable: TStreamable, options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly replay?: number; }): Optional>; useStream(factory: Factory, dep: readonly unknown[], options?: { readonly priority?: 1 | 2 | 3 | 4 | 5; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly replay?: number; }): Optional>; } type Signature = ReactModule; export declare const createComponent: Signature["createComponent"]; export declare const useDispatcher: Signature["useDispatcher"]; export declare const useDisposable: Signature["useDisposable"]; export declare const useEnumerator: Signature["useEnumerator"]; export declare const useListen: Signature["useListen"]; export declare const useObserve: Signature["useObserve"]; export declare const usePauseable: Signature["usePauseable"]; export declare const useStream: Signature["useStream"]; export declare const useFlow: Signature["useFlow"]; export {};