export type IUnsubscriber = () => void;
export interface ISubscription {
	unsubscribe: IUnsubscriber;
	add(item: ISubscription | IUnsubscriber): ISubscription;
}
export interface IObservable<T> {
	subscribe(listener: IListener<T>, error?: IListener<Error | unknown>): ISubscription;
	/**
	* @deprecated Глушить ошибки не стоит.
	* Раньше у нас они по-умолчанию ошибочно глушились что маскировало многие исключения, в том числе грубые ошибки
	* Этот метод нужен чтобы временно поддержать старрое поведение пока маскиуремые ошибки не исправятся
	*/
	setSuppressErrors(suppress: boolean): void;
	pipe<T1>(op1: IOperator<T, T1>): IObservable<T1>;
	pipe<
		T1,
		T2
	>(op1: IOperator<T, T1>, op2: IOperator<T1, T2>): IObservable<T2>;
	pipe<
		T1,
		T2,
		T3
	>(op1: IOperator<T, T1>, op2: IOperator<T1, T2>, op3: IOperator<T2, T3>): IObservable<T3>;
	pipe<
		T1,
		T2,
		T3,
		T4
	>(op1: IOperator<T, T1>, op2: IOperator<T1, T2>, op3: IOperator<T2, T3>, op4: IOperator<T3, T4>): IObservable<T4>;
	pipe<
		T1,
		T2,
		T3,
		T4,
		T5
	>(op1: IOperator<T, T1>, op2: IOperator<T1, T2>, op3: IOperator<T2, T3>, op4: IOperator<T3, T4>, op5: IOperator<T4, T5>): IObservable<T5>;
}
export interface IValue<T> {
	getValue(): T;
}
export interface IEmitter<T> {
	next(value: T): void;
	error?(value: Error | unknown): void;
}
export interface IValueObservable<T> extends IObservable<T>, IValue<T> {}
export interface ISubject<T> extends IEmitter<T>, IObservable<T> {}
export interface IValueSubject<T> extends IEmitter<T>, IValueObservable<T> {}
export type IListener<T> = IEmitter<T> | ((value: T) => void) | ((value: T) => Promise<void>);
export type IOperator<
	TInput,
	TOutput = TInput
> = (input: IObservable<TInput>) => IObservable<TOutput>;
export type TypeOfObservable<TObservable> = TObservable extends IObservable<infer TType> ? TType : never;