import { EnumerableLike } from "../collections.js"; import { Computation, Computation_T, Computation_type } from "../computations.js"; import { DeferredObservableLike, DeferredObservableWithSideEffectsLike, DispatcherLike, MulticastObservableLike, ObservableLike, ObservableLike_isDeferred, ObservableLike_isMulticasted, ObservableLike_isPure, ObservableLike_isRunnable, ObserverLike, PureDeferredObservableLike, PureObservableLike, PureRunnableLike, RunnableLike, RunnableWithSideEffectsLike, SchedulerLike } from "../concurrent.js"; import { EventSourceLike, StoreLike } from "../events.js"; import { Equality, Factory, Function1, Function2, Optional, Predicate, Reducer, SideEffect, SideEffect1, Tuple2, Tuple3, Tuple4, Tuple5, Tuple6, Tuple7, Tuple8, Tuple9, Updater } from "../functions.js"; import { BackpressureStrategy, DisposableLike, QueueableLike } from "../utils.js"; export type PureStatelessObservableOperator = >(observable: TObservableIn) => TObservableIn extends PureRunnableLike ? PureRunnableLike : TObservableIn extends RunnableWithSideEffectsLike ? RunnableWithSideEffectsLike : TObservableIn extends RunnableLike ? RunnableLike : TObservableIn extends PureDeferredObservableLike ? PureDeferredObservableLike : TObservableIn extends DeferredObservableWithSideEffectsLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends DeferredObservableLike ? DeferredObservableLike : TObservableIn extends MulticastObservableLike ? MulticastObservableLike : ObservableLike; export type PureStatefulObservableOperator> = (observable: TObservableIn) => TObservableIn extends PureRunnableLike ? PureRunnableLike : TObservableIn extends RunnableWithSideEffectsLike ? RunnableWithSideEffectsLike : TObservableIn extends RunnableLike ? RunnableLike : TObservableIn extends PureDeferredObservableLike ? PureDeferredObservableLike : TObservableIn extends MulticastObservableLike ? PureDeferredObservableLike : TObservableIn extends DeferredObservableWithSideEffectsLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends DeferredObservableLike ? DeferredObservableLike : ObservableLike; export type DeferringObservableOperator> = (obs: TObservableIn) => TObservableIn extends PureObservableLike ? PureDeferredObservableLike : DeferredObservableWithSideEffectsLike; export type ObservableOperatorWithSideEffects = >(observable: TObservableIn) => TObservableIn extends PureRunnableLike ? RunnableWithSideEffectsLike : TObservableIn extends RunnableWithSideEffectsLike ? RunnableWithSideEffectsLike : TObservableIn extends RunnableLike ? RunnableWithSideEffectsLike : TObservableIn extends PureDeferredObservableLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends DeferredObservableWithSideEffectsLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends DeferredObservableLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends MulticastObservableLike ? DeferredObservableWithSideEffectsLike : ObservableLike; export declare const PureRunnableType: Pick; export declare const RunnableWithSideEffectsType: Pick; export declare const PureDeferredObservableType: Pick; export declare const DeferredObservableWithSideEffectsType: Pick; /** * @noInheritDoc */ export interface PureRunnableComputation extends Computation { readonly [Computation_type]?: PureRunnableLike; } /** * @noInheritDoc */ export interface RunnableWithSideEffectsComputation extends Computation { readonly [Computation_type]?: RunnableWithSideEffectsLike; } /** * @noInheritDoc */ export interface PuredDeferredObservableComputation extends Computation { readonly [Computation_type]?: PureDeferredObservableLike; } /** * @noInheritDoc */ export interface DeferredObservableWithSideEffectsComputation extends Computation { readonly [Computation_type]?: DeferredObservableWithSideEffectsLike; } /** * @noInheritDoc */ export interface MulticastObservableComputation extends Computation { readonly [Computation_type]?: MulticastObservableLike; } export declare const BatchedComputeMode = "batched"; export declare const CombineLatestComputeMode = "combine-latest"; export type ComputeMode = typeof BatchedComputeMode | typeof CombineLatestComputeMode; export declare const ThrottleFirstMode = "first"; export declare const ThrottleLastMode = "last"; export declare const ThrottleIntervalMode = "interval"; export type ThrottleMode = typeof ThrottleFirstMode | typeof ThrottleLastMode | typeof ThrottleIntervalMode; /** * @noInheritDoc */ export interface ObservableModule { backpressureStrategy(capacity: number, backpressureStrategy: BackpressureStrategy): PureStatefulObservableOperator; buffer(options?: { readonly count?: number; }): PureStatefulObservableOperator; catchError(onError: SideEffect1): PureStatefulObservableOperator; combineLatest(a: PureRunnableLike, b: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike, g: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike, g: PureRunnableLike, h: PureRunnableLike): PureRunnableLike>; combineLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike, g: PureRunnableLike, h: PureRunnableLike, i: PureRunnableLike): PureRunnableLike>; combineLatest(a: RunnableLike, b: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike, g: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike, g: RunnableLike, h: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike, g: RunnableLike, h: RunnableLike, i: RunnableLike): RunnableWithSideEffectsLike>; combineLatest(a: PureObservableLike, b: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike, g: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike, g: PureObservableLike, h: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike, g: PureObservableLike, h: PureObservableLike, i: PureObservableLike): PureDeferredObservableLike>; combineLatest(a: ObservableLike, b: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike, g: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike, g: ObservableLike, h: ObservableLike): DeferredObservableWithSideEffectsLike>; combineLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike, g: ObservableLike, h: ObservableLike, i: ObservableLike): DeferredObservableWithSideEffectsLike>; computeDeferred(computation: Factory, options?: { readonly mode?: ComputeMode; }): DeferredObservableWithSideEffectsLike; computeRunnable(computation: Factory, options?: { readonly mode?: ComputeMode; }): RunnableWithSideEffectsLike; concat(fst: PureRunnableLike, snd: PureRunnableLike, ...tail: readonly PureRunnableLike[]): PureRunnableLike; concat(fst: PureDeferredObservableLike, snd: PureDeferredObservableLike, ...tail: readonly PureDeferredObservableLike[]): PureDeferredObservableLike; concat(fst: RunnableLike, snd: RunnableLike, ...tail: readonly RunnableLike[]): RunnableWithSideEffectsLike; concat(fst: DeferredObservableLike, snd: DeferredObservableLike, ...tail: readonly DeferredObservableLike[]): DeferredObservableWithSideEffectsLike; concat(fst: MulticastObservableLike, snd: PureDeferredObservableLike, ...tail: readonly PureDeferredObservableLike[]): MulticastObservableLike; concat(fst: MulticastObservableLike, snd: DeferredObservableLike, ...tail: readonly DeferredObservableLike[]): DeferredObservableWithSideEffectsLike; concatAll(): PureStatefulObservableOperator, T>; concatAll(options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator, T>; concatAll(options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects, T>; concatAll(options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator, T>; concatAll(options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1>, DeferredObservableWithSideEffectsLike>; concatMany(observables: readonly PureRunnableLike[]): PureRunnableLike; concatMany(observables: readonly PureDeferredObservableLike[]): PureDeferredObservableLike; concatMany(observables: readonly RunnableLike[]): RunnableWithSideEffectsLike; concatMany(observables: readonly DeferredObservableLike[]): DeferredObservableWithSideEffectsLike; concatMany(observables: readonly [ MulticastObservableLike, ...(readonly PureDeferredObservableLike[]) ]): PureDeferredObservableLike; concatMany(observables: readonly [ MulticastObservableLike, ...(readonly DeferredObservableLike[]) ]): DeferredObservableWithSideEffectsLike; concatMap(selector: Function1>): PureStatefulObservableOperator; concatMap(selector: Function1>, options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator; concatMap(selector: Function1>, options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects; concatMap(selector: Function1>, options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator; concatMap(selector: Function1>, options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1, DeferredObservableWithSideEffectsLike>; concatWith(snd: PureRunnableLike, ...tail: readonly PureRunnableLike[]): PureStatefulObservableOperator; concatWith(snd: RunnableLike, ...tail: readonly RunnableLike[]): ObservableOperatorWithSideEffects; concatWith(snd: PureDeferredObservableLike, ...tail: readonly PureDeferredObservableLike[]): DeferringObservableOperator; concatWith(snd: DeferredObservableLike, ...tail: readonly DeferredObservableLike[]): Function1 | MulticastObservableLike, DeferredObservableWithSideEffectsLike>; create(f: SideEffect1>): DeferredObservableWithSideEffectsLike; currentTime: PureRunnableLike; debug(): ObservableOperatorWithSideEffects; decodeWithCharset(options?: { readonly charset?: string; readonly fatal?: boolean; readonly ignoreBOM?: boolean; }): PureStatefulObservableOperator; defer(f: Factory>): PureDeferredObservableLike; dispatchTo(dispatcher: DispatcherLike): ObservableOperatorWithSideEffects; distinctUntilChanged(options?: { readonly equality?: Equality; }): PureStatefulObservableOperator; empty(): MulticastObservableLike; empty(options?: { readonly delay: number; }): PureRunnableLike; encodeUtf8(): PureStatefulObservableOperator; endWith(value: T, ...values: readonly T[]): PureStatefulObservableOperator; enqueue(queue: QueueableLike): ObservableOperatorWithSideEffects; exhaust(): PureStatefulObservableOperator, T>; exhaust(options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator, T>; exhaust(options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects, T>; exhaust(options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator, T>; exhaust(options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1>, DeferredObservableWithSideEffectsLike>; exhaustMap(selector: Function1>): PureStatefulObservableOperator; exhaustMap(selector: Function1>, options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator; exhaustMap(selector: Function1>, options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects; exhaustMap(selector: Function1>, options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator; exhaustMap(selector: Function1>, options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1, DeferredObservableWithSideEffectsLike>; firstAsync(scheduler: SchedulerLike, options?: { readonly capacity?: number; readonly backpressureStrategy?: BackpressureStrategy; }): Function1, Promise>>; flatMapAsync(f: Function2>): Function1, DeferredObservableWithSideEffectsLike>; flatMapIterable(selector: Function1>): ObservableOperatorWithSideEffects; forEach(effect: SideEffect1): ObservableOperatorWithSideEffects; forkMerge(fst: Function1, PureRunnableLike>, snd: Function1, PureRunnableLike>, ...tail: readonly Function1, PureRunnableLike>[]): >(obs: TObservableIn) => TObservableIn extends MulticastObservableLike ? PureRunnableLike : DeferredObservableWithSideEffectsLike; forkMerge(fst: Function1, PureDeferredObservableLike>, snd: Function1, PureDeferredObservableLike>, ...tail: readonly Function1, PureDeferredObservableLike>[]): >(obs: TObservableIn) => TObservableIn extends MulticastObservableLike ? PureDeferredObservableLike : DeferredObservableWithSideEffectsLike; forkMerge(fst: Function1, RunnableWithSideEffectsLike>, snd: Function1, RunnableWithSideEffectsLike>, ...tail: readonly Function1, RunnableWithSideEffectsLike>[]): >(obs: TObservableIn) => TObservableIn extends MulticastObservableLike ? RunnableWithSideEffectsLike : DeferredObservableWithSideEffectsLike; forkMerge(fst: Function1, MulticastObservableLike>, snd: Function1, MulticastObservableLike>, ...tail: readonly Function1, MulticastObservableLike>[]): >(obs: TObservableIn) => TObservableIn extends MulticastObservableLike ? MulticastObservableLike : DeferredObservableWithSideEffectsLike; forkMerge(fst: Function1, PureObservableLike>, snd: Function1, PureObservableLike>, ...tail: readonly Function1, PureObservableLike>[]): >(obs: TObservableIn) => TObservableIn extends MulticastObservableLike ? PureDeferredObservableLike : DeferredObservableWithSideEffectsLike; forkMerge(fst: Function1, ObservableLike>, snd: Function1, ObservableLike>, ...tail: readonly Function1, ObservableLike>[]): Function1, DeferredObservableWithSideEffectsLike>; fromAsyncFactory(): Function1>, DeferredObservableWithSideEffectsLike>; fromAsyncIterable(): Function1, DeferredObservableWithSideEffectsLike>; fromEnumerable(options?: { readonly delay: number; readonly delayStart?: boolean; }): Function1, PureRunnableLike>; fromEventSource(): Function1, MulticastObservableLike>; fromIterable(options?: { readonly delay: number; readonly delayStart?: boolean; }): Function1, RunnableWithSideEffectsLike>; fromPromise(): Function1, MulticastObservableLike>; fromReadonlyArray(options?: { readonly delay?: number; readonly delayStart?: boolean; readonly count?: number; readonly start?: number; }): Function1, PureRunnableLike>; fromStore(): Function1, MulticastObservableLike>; fromValue(options?: { readonly delay: number; }): Function1>; generate(generator: Updater, initialValue: Factory, options?: { readonly delay?: number; readonly delayStart?: boolean; }): PureRunnableLike; ignoreElements(): PureStatelessObservableOperator; keep(predicate: Predicate): PureStatelessObservableOperator; keyFrame(duration: number, options?: { readonly easing?: Function1; }): PureRunnableLike; lastAsync(scheduler: SchedulerLike, options?: { readonly capacity?: number; readonly backpressureStrategy?: BackpressureStrategy; }): Function1, Promise>>; log(): ObservableOperatorWithSideEffects; map(selector: Function1): PureStatelessObservableOperator; merge(fst: PureRunnableLike, snd: PureRunnableLike, ...tail: readonly PureRunnableLike[]): PureRunnableLike; merge(fst: PureDeferredObservableLike, snd: PureDeferredObservableLike, ...tail: readonly PureDeferredObservableLike[]): PureDeferredObservableLike; merge(fst: RunnableLike, snd: RunnableLike, ...tail: readonly RunnableLike[]): RunnableWithSideEffectsLike; merge(fst: MulticastObservableLike, snd: MulticastObservableLike, ...tail: readonly MulticastObservableLike[]): MulticastObservableLike; merge(fst: PureObservableLike, snd: PureObservableLike, ...tail: readonly PureObservableLike[]): PureDeferredObservableLike; merge(fst: ObservableLike, snd: ObservableLike, ...tail: readonly ObservableLike[]): DeferredObservableWithSideEffectsLike; mergeAll(options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): PureStatefulObservableOperator, T>; mergeAll(options: { readonly innerType: typeof PureRunnableType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): PureStatefulObservableOperator, T>; mergeAll(options: { readonly innerType: typeof RunnableWithSideEffectsType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): ObservableOperatorWithSideEffects, T>; mergeAll(options: { readonly innerType: typeof PureDeferredObservableType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): DeferringObservableOperator, T>; mergeAll(options?: { readonly innerType: typeof DeferredObservableWithSideEffectsType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): Function1>, DeferredObservableWithSideEffectsLike>; mergeMany(observables: readonly PureRunnableLike[]): PureRunnableLike; mergeMany(observables: readonly PureDeferredObservableLike[]): PureDeferredObservableLike; mergeMany(observables: readonly RunnableLike[]): RunnableWithSideEffectsLike; mergeMany(observables: readonly DeferredObservableLike[]): DeferredObservableWithSideEffectsLike; mergeMany(observables: readonly MulticastObservableLike[]): MulticastObservableLike; mergeMany(observables: readonly PureObservableLike[]): PureDeferredObservableLike; mergeMany(observables: readonly ObservableLike[]): DeferredObservableWithSideEffectsLike; mergeMap(selector: Function1>, options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): PureStatefulObservableOperator; mergeMap(selector: Function1>, options: { readonly innerType: typeof PureRunnableType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): PureStatefulObservableOperator; mergeMap(selector: Function1>, options: { readonly innerType: typeof RunnableWithSideEffectsType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): ObservableOperatorWithSideEffects; mergeMap(selector: Function1>, options: { readonly innerType: typeof PureDeferredObservableType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): DeferringObservableOperator; mergeMap(selector: Function1>, options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly concurrency?: number; }): Function1, DeferredObservableWithSideEffectsLike>; mergeWith(snd: PureRunnableLike, ...tail: readonly PureRunnableLike[]): PureStatefulObservableOperator; mergeWith(snd: RunnableLike, ...tail: readonly RunnableLike[]): ObservableOperatorWithSideEffects; mergeWith(snd: PureDeferredObservableLike, ...tail: readonly PureDeferredObservableLike[]): DeferringObservableOperator; mergeWith(snd: PureObservableLike, ...tail: readonly PureObservableLike[]): PureStatefulObservableOperator; mergeWith(snd: ObservableLike, ...tail: readonly ObservableLike[]): Function1, DeferredObservableWithSideEffectsLike>; multicast(scheduler: SchedulerLike, options?: { readonly autoDispose?: boolean; readonly replay?: number; readonly capacity?: number; readonly backpressureStrategy?: BackpressureStrategy; }): Function1, MulticastObservableLike & DisposableLike>; never(): MulticastObservableLike; onSubscribe(f: Factory): ObservableOperatorWithSideEffects; onSubscribe(f: Factory>>): ObservableOperatorWithSideEffects; onSubscribe(f: SideEffect): ObservableOperatorWithSideEffects; pairwise(): PureStatefulObservableOperator>; reduce(reducer: Reducer, initialValue: Factory): Function1, TAcc>; repeat(predicate: Predicate): PureStatefulObservableOperator>; repeat(count: number): PureStatefulObservableOperator>; repeat(): PureStatefulObservableOperator>; retry(shouldRetry?: (count: number, error: Error) => boolean): PureStatefulObservableOperator>; run(options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly maxMicroTaskTicks?: number; }): SideEffect1>; scan(reducer: Reducer, initialValue: Factory): PureStatefulObservableOperator; scanMany(scanner: Function2>, initialValue: Factory): PureStatefulObservableOperator; scanMany(scanner: Function2>, initialValue: Factory, options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator; scanMany(scanner: Function2>, initialValue: Factory, options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects; scanMany(scanner: Function2>, initialValue: Factory, options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator; scanMany(scanner: Function2>, initialValue: Factory, options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1, DeferredObservableWithSideEffectsLike>; skipFirst(options?: { readonly count?: number; }): PureStatefulObservableOperator; spring(options?: { readonly stiffness?: number; readonly damping?: number; readonly precision?: number; }): PureRunnableLike; startWith(value: T, ...values: readonly T[]): PureStatefulObservableOperator; subscribe(scheduler: SchedulerLike, options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): Function1, DisposableLike>; subscribeOn(scheduler: SchedulerLike, options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): >(observable: TObservableIn) => TObservableIn extends PureDeferredObservableLike ? PureDeferredObservableLike : TObservableIn extends MulticastObservableLike ? MulticastObservableLike : TObservableIn extends RunnableWithSideEffectsLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends DeferredObservableWithSideEffectsLike ? DeferredObservableWithSideEffectsLike : TObservableIn extends DeferredObservableLike ? DeferredObservableLike : ObservableLike; switchAll(): PureStatefulObservableOperator, T>; switchAll(options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator, T>; switchAll(options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects, T>; switchAll(options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator, T>; switchAll(options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1>, DeferredObservableWithSideEffectsLike>; switchMap(selector: Function1>): PureStatefulObservableOperator; switchMap(selector: Function1>, options: { readonly innerType: typeof PureRunnableType; }): PureStatefulObservableOperator; switchMap(selector: Function1>, options: { readonly innerType: typeof RunnableWithSideEffectsType; }): ObservableOperatorWithSideEffects; switchMap(selector: Function1>, options: { readonly innerType: typeof PureDeferredObservableType; }): DeferringObservableOperator; switchMap(selector: Function1>, options: { readonly innerType: typeof DeferredObservableWithSideEffectsType; }): Function1, DeferredObservableWithSideEffectsLike>; takeFirst(options?: { readonly count?: number; }): PureStatefulObservableOperator; takeLast(options?: { readonly count?: number; }): PureStatefulObservableOperator; takeUntil(notifier: PureRunnableLike): PureStatefulObservableOperator; takeUntil(notifier: RunnableWithSideEffectsLike): ObservableOperatorWithSideEffects; takeUntil(notifier: DeferredObservableWithSideEffectsLike): Function1, DeferredObservableWithSideEffectsLike>; takeUntil(notifier: MulticastObservableLike): DeferringObservableOperator; takeWhile(predicate: Predicate, options?: { readonly inclusive?: boolean; }): PureStatefulObservableOperator; throttle(duration: number, options?: { readonly mode?: ThrottleMode; }): PureStatefulObservableOperator; throwIfEmpty(factory: Factory, options?: undefined): PureStatefulObservableOperator; throws(options?: { readonly raise?: Factory; readonly delay?: number; }): PureRunnableLike; toEventSource(scheduler: SchedulerLike, options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): Function1, EventSourceLike>; toReadonlyArray(options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; readonly maxMicroTaskTicks?: number; }): Function1, ReadonlyArray>; toReadonlyArrayAsync(scheduler: SchedulerLike, options?: { readonly backpressureStrategy?: BackpressureStrategy; readonly capacity?: number; }): Function1, Promise>>; withCurrentTime(selector: Function2): PureStatefulObservableOperator; withLatestFrom(other: PureRunnableLike, selector: Function2): PureStatefulObservableOperator; withLatestFrom(other: RunnableWithSideEffectsLike, selector: Function2): ObservableOperatorWithSideEffects; withLatestFrom(other: DeferredObservableWithSideEffectsLike, selector: Function2): Function1, DeferredObservableWithSideEffectsLike>; withLatestFrom(other: MulticastObservableLike, selector: Function2): DeferringObservableOperator; zipLatest(a: PureRunnableLike, b: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike, g: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike, g: PureRunnableLike, h: PureRunnableLike): PureRunnableLike>; zipLatest(a: PureRunnableLike, b: PureRunnableLike, c: PureRunnableLike, d: PureRunnableLike, e: PureRunnableLike, f: PureRunnableLike, g: PureRunnableLike, h: PureRunnableLike, i: PureRunnableLike): PureRunnableLike>; zipLatest(a: RunnableLike, b: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike, g: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike, g: RunnableLike, h: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: RunnableLike, b: RunnableLike, c: RunnableLike, d: RunnableLike, e: RunnableLike, f: RunnableLike, g: RunnableLike, h: RunnableLike, i: RunnableLike): RunnableWithSideEffectsLike>; zipLatest(a: PureObservableLike, b: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike, g: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike, g: PureObservableLike, h: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: PureObservableLike, b: PureObservableLike, c: PureObservableLike, d: PureObservableLike, e: PureObservableLike, f: PureObservableLike, g: PureObservableLike, h: PureObservableLike, i: PureObservableLike): PureDeferredObservableLike>; zipLatest(a: ObservableLike, b: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike, g: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike, g: ObservableLike, h: ObservableLike): DeferredObservableWithSideEffectsLike>; zipLatest(a: ObservableLike, b: ObservableLike, c: ObservableLike, d: ObservableLike, e: ObservableLike, f: ObservableLike, g: ObservableLike, h: ObservableLike, i: ObservableLike): DeferredObservableWithSideEffectsLike>; } export type Signature = ObservableModule; export declare const backpressureStrategy: Signature["backpressureStrategy"]; export declare const buffer: Signature["buffer"]; export declare const catchError: Signature["catchError"]; export declare const combineLatest: Signature["combineLatest"]; export declare const computeDeferred: Signature["computeDeferred"]; export declare const computeRunnable: Signature["computeRunnable"]; export declare const concat: Signature["concat"]; export declare const concatAll: Signature["concatAll"]; export declare const concatMany: Signature["concatMany"]; export declare const concatMap: Signature["concatMap"]; export declare const concatWith: Signature["concatWith"]; export declare const create: Signature["create"]; export declare const currentTime: Signature["currentTime"]; export declare const debug: Signature["debug"]; export declare const decodeWithCharset: Signature["decodeWithCharset"]; export declare const defer: Signature["defer"]; export declare const dispatchTo: Signature["dispatchTo"]; export declare const distinctUntilChanged: Signature["distinctUntilChanged"]; export declare const empty: Signature["empty"]; export declare const encodeUtf8: Signature["encodeUtf8"]; export declare const endWith: Signature["endWith"]; export declare const enqueue: Signature["enqueue"]; export declare const exhaust: Signature["exhaust"]; export declare const exhaustMap: Signature["exhaustMap"]; export declare const firstAsync: Signature["firstAsync"]; export declare const flatMapAsync: Signature["flatMapAsync"]; export declare const flatMapIterable: Signature["flatMapIterable"]; export declare const forEach: Signature["forEach"]; export declare const forkMerge: Signature["forkMerge"]; export declare const fromAsyncFactory: Signature["fromAsyncFactory"]; export declare const fromAsyncIterable: Signature["fromAsyncIterable"]; export declare const fromEnumerable: Signature["fromEnumerable"]; export declare const fromEventSource: Signature["fromEventSource"]; export declare const fromIterable: Signature["fromIterable"]; export declare const fromPromise: Signature["fromPromise"]; export declare const fromReadonlyArray: Signature["fromReadonlyArray"]; export declare const fromStore: Signature["fromStore"]; export declare const fromValue: Signature["fromValue"]; export declare const generate: Signature["generate"]; export declare const ignoreElements: Signature["ignoreElements"]; export declare const keep: Signature["keep"]; export declare const keyFrame: Signature["keyFrame"]; export declare const lastAsync: Signature["lastAsync"]; export declare const log: Signature["log"]; export declare const map: Signature["map"]; export declare const merge: Signature["merge"]; export declare const mergeAll: Signature["mergeAll"]; export declare const mergeMap: Signature["mergeMap"]; export declare const mergeMany: Signature["mergeMany"]; export declare const mergeWith: Signature["mergeWith"]; export declare const multicast: Signature["multicast"]; export declare const never: Signature["never"]; export declare const onSubscribe: Signature["onSubscribe"]; export declare const pairwise: Signature["pairwise"]; export declare const reduce: Signature["reduce"]; export declare const repeat: Signature["repeat"]; export declare const retry: Signature["retry"]; export declare const run: Signature["run"]; export declare const scan: Signature["scan"]; export declare const scanMany: Signature["scanMany"]; export declare const skipFirst: Signature["skipFirst"]; export declare const spring: Signature["spring"]; export declare const startWith: Signature["startWith"]; export declare const subscribe: Signature["subscribe"]; export declare const subscribeOn: Signature["subscribeOn"]; export declare const switchAll: Signature["switchAll"]; export declare const switchMap: Signature["switchMap"]; export declare const takeFirst: Signature["takeFirst"]; export declare const takeLast: Signature["takeLast"]; export declare const takeUntil: Signature["takeUntil"]; export declare const takeWhile: Signature["takeWhile"]; export declare const throttle: Signature["throttle"]; export declare const throwIfEmpty: Signature["throwIfEmpty"]; export declare const throws: Signature["throws"]; export declare const toEventSource: Signature["toEventSource"]; export declare const toReadonlyArray: Signature["toReadonlyArray"]; export declare const toReadonlyArrayAsync: Signature["toReadonlyArrayAsync"]; export declare const withCurrentTime: Signature["withCurrentTime"]; export declare const withLatestFrom: Signature["withLatestFrom"]; export declare const zipLatest: Signature["zipLatest"];