27 lines
1002 B
TypeScript
27 lines
1002 B
TypeScript
|
type Callback = (...args: any[]) => any
|
||
|
|
|
||
|
|
export declare function cancel(): symbol
|
||
|
|
export declare function off(): symbol
|
||
|
|
export declare function install(name: string, fn: Callback): any
|
||
|
|
|
||
|
|
export type ErreStream<T = unknown, TReturn = any, TNext = unknown> = {
|
||
|
|
on: {
|
||
|
|
value: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
error: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
end: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
}
|
||
|
|
off: {
|
||
|
|
value: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
error: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
end: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
}
|
||
|
|
connect: (fn: Callback) => ErreStream<T, TReturn, TNext>
|
||
|
|
push: (value: any) => ErreStream<T, TReturn, TNext>
|
||
|
|
end: () => ErreStream<T, TReturn, TNext>
|
||
|
|
fork: () => ErreStream<T, TReturn, TNext>
|
||
|
|
} & Generator<T, TReturn, TNext>
|
||
|
|
|
||
|
|
declare const erre: <T = unknown, TReturn = any, TNext = unknown>(...fns: any[]) => ErreStream<T, TReturn, TNext>
|
||
|
|
|
||
|
|
export default erre
|