// This definition document heavily references
// the original declaration of Michael de Wit <https://github.com/mjwwit>

import {
    count as countImport,
    empty as emptyImport,
    error as errorImport,
    infinite as infiniteImport,
    keys as keysImport,
    once as onceImport,
    values as valuesImport,
} from "./sources";

import {
    asyncMap as asyncMapImport,
    filter as filterImport,
    filterNot as filterNotImport,
    flatten as flattenImport,
    map as mapImport,
    nonUnique as nonUniqueImport,
    take as takeImport,
    through as throughImport,
    unique as uniqueImport,
} from "./throughs";

import {
    collect as collectImport,
    concat as concatImport,
    drain as drainImport,
    find as findImport,
    log as logImport,
    onEnd as onEndImport,
    reduce as reduceImport,
} from "./sinks";

declare namespace pull {
    type Abort = Error | boolean | null;
    type EndOrError = Abort;
    type SourceCallback<T> = (end: EndOrError, data?: T) => void;

    type Source<T> = (endOrError: Abort, cb: SourceCallback<T>) => void;
    type Sink<T> = (source: Source<T>) => void;
    type Through<T, U> = (source: Source<T>) => Source<U>;

    interface DuplexSource<In> {
        source: Source<In>;
    }
    interface DuplexSink<Out> {
        sink: Sink<Out>;
    }

    type Duplex<In, Out> = DuplexSource<In> & DuplexSink<Out>;
    type DuplexThrough<In, Out> = DuplexSource<In> & DuplexSink<Out>;

    type PossibleSource<T> = Source<T> | DuplexSource<T>;
    type PossibleSink<T> = Sink<T> | DuplexSink<T>;
    type PossibleThrough<In, Out> = Through<In, Out> | DuplexThrough<In, Out>;

    const count: typeof countImport;
    const empty: typeof emptyImport;
    const error: typeof errorImport;
    const infinite: typeof infiniteImport;
    const keys: typeof keysImport;
    const once: typeof onceImport;
    const values: typeof valuesImport;

    const asyncMap: typeof asyncMapImport;
    const filterNot: typeof filterNotImport;
    const filter: typeof filterImport;
    const flatten: typeof flattenImport;
    const map: typeof mapImport;
    const nonUnique: typeof nonUniqueImport;
    const take: typeof takeImport;
    const through: typeof throughImport;
    const unique: typeof uniqueImport;

    const collect: typeof collectImport;
    const concat: typeof concatImport;
    const drain: typeof drainImport;
    const find: typeof findImport;
    const log: typeof logImport;
    const onEnd: typeof onEndImport;
    const reduce: typeof reduceImport;
}

/**
 * Pipe data through a number of `pull-stream`s
 */
declare function pull(): void;

declare function pull<Out>(source: pull.PossibleSource<Out>): pull.Source<Out>;
declare function pull<In, Out>(source: pull.PossibleSource<In>, t1: pull.PossibleThrough<In, Out>): pull.Source<Out>;
declare function pull<In, P1, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, Out>,
): pull.Source<Out>;
declare function pull<In, P1, P2, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, Out>,
): pull.Source<Out>;
declare function pull<In, P1, P2, P3, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, Out>,
): pull.Source<Out>;
declare function pull<In, P1, P2, P3, P4, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, Out>,
): pull.Source<Out>;
declare function pull<In, P1, P2, P3, P4, P5, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, P5>,
    t6: pull.PossibleThrough<P5, Out>,
): pull.Source<Out>;

declare function pull<In, Out>(t1: pull.Through<In, Out>): pull.Through<In, Out>;
declare function pull<In, P1, Out>(t1: pull.Through<In, P1>, t2: pull.PossibleThrough<P1, Out>): pull.Through<In, Out>;
declare function pull<In, P1, P2, Out>(
    t1: pull.Through<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, Out>,
): pull.Through<In, Out>;
declare function pull<In, P1, P2, P3, Out>(
    t1: pull.Through<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, Out>,
): pull.Through<In, Out>;
declare function pull<In, P1, P2, P3, P4, Out>(
    t1: pull.Through<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, Out>,
): pull.Through<In, Out>;
declare function pull<In, P1, P2, P3, P4, P5, Out>(
    t1: pull.Through<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, P5>,
    t6: pull.PossibleThrough<P5, Out>,
): pull.Through<In, Out>;

declare function pull<In>(sink: pull.PossibleSink<In>): pull.Sink<In>;
declare function pull<In, Out>(t1: pull.PossibleThrough<In, Out>, sink: pull.PossibleSink<Out>): pull.Sink<In>;
declare function pull<In, P1, Out>(
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, Out>,
    sink: pull.PossibleSink<Out>,
): pull.Sink<In>;
declare function pull<In, P1, P2, Out>(
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, Out>,
    sink: pull.PossibleSink<Out>,
): pull.Sink<In>;
declare function pull<In, P1, P2, P3, Out>(
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, Out>,
    sink: pull.PossibleSink<Out>,
): pull.Sink<In>;
declare function pull<In, P1, P2, P3, P4, Out>(
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, Out>,
    sink: pull.PossibleSink<Out>,
): pull.Sink<In>;
declare function pull<In, P1, P2, P3, P4, P5, Out>(
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, P5>,
    t6: pull.PossibleThrough<P5, Out>,
    sink: pull.PossibleSink<Out>,
): pull.Sink<In>;

declare function pull<InOut>(source: pull.PossibleSource<InOut>, sink: pull.PossibleSink<InOut>): void;
declare function pull<In, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, Out>,
    sink: pull.PossibleSink<Out>,
): void;
declare function pull<In, P1, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, Out>,
    sink: pull.PossibleSink<Out>,
): void;
declare function pull<In, P1, P2, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, Out>,
    sink: pull.PossibleSink<Out>,
): void;
declare function pull<In, P1, P2, P3, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, Out>,
    sink: pull.PossibleSink<Out>,
): void;
declare function pull<In, P1, P2, P3, P4, Out>(
    source: pull.PossibleSource<In>,
    t1: pull.PossibleThrough<In, P1>,
    t2: pull.PossibleThrough<P1, P2>,
    t3: pull.PossibleThrough<P2, P3>,
    t4: pull.PossibleThrough<P3, P4>,
    t5: pull.PossibleThrough<P4, Out>,
    sink: pull.PossibleSink<Out>,
): void;

declare function pull(
    ...pullStreams: ReadonlyArray<pull.PossibleSource<any> | pull.PossibleSink<any> | pull.PossibleThrough<any, any>>
    // eslint-disable-next-line @typescript-eslint/no-invalid-void-type
): pull.Source<any> | pull.Sink<any> | pull.Through<any, any> | void;

export = pull;