import * as Event from "./Event";
import { EventStream } from "./EventStream";
import { HKT, Observable } from "./Observable";
import { Property } from "./Property";
export declare type In<ObsType, ValueType> = HKT<ObsType> & Observable<ValueType>;
export declare type Out<ObsType, ValueType> = ObsType extends Property<any> ? Property<ValueType> : ObsType extends EventStream<any> ? EventStream<ValueType> : Observable<ValueType>;
export declare type JSMap<K, V> = Map<K, V>;
export declare type JSSet<V> = Set<V>;
export declare type Projection<A, B> = (val: A) => B;
export declare type Predicate<A> = (val: A) => boolean;
export declare type Accum<S, T> = (state: S, value: T) => S;
export declare type FlatAccum<S, T> = (state: S, value: T) => S | Observable<S>;
export declare type Dispose = () => void;
export declare type AnyEvent<T> = Event.Next<T> | Event.Error | Event.End;
export declare type AnyObs<A> = Property<A> | EventStream<A>;
export declare type Handler<T> = (event: AnyEvent<T>) => typeof Event.noMore | any;
export declare type ValueHandler<T> = (val: T) => typeof Event.noMore | any;
export declare type ValuesHandler<T> = (...vals: T[]) => typeof Event.noMore | any;
export declare type ErrorHandler = (err: Error) => typeof Event.noMore | any;
export declare type EndHandler = () => void;
export declare type SinkEvent<T> = T | AnyEvent<T> | Array<T | AnyEvent<T>>;
export declare type SinkResult = typeof Event.noMore | typeof Event.more;
export declare type Sink<T> = (event: SinkEvent<T>) => SinkResult;
export declare type Subscribe<T> = (sink: Sink<T>) => Dispose | any;
export declare type AsyncCallback<T> = (callback: (result: T | AnyEvent<T>) => void) => void;
export declare type AsyncNodeCallback<T> = (callback: (error: Error | null, result?: T | AnyEvent<T>) => void) => void;