interface ILoader<T, R> {
    next: (value: T) => void;
    pipe: {
        (): Observable<R>;
        <A>(op1: OperatorFunction<R, A>): Observable<A>;
        <A, B>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
        ): Observable<B>;
        <A, B, C>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
        ): Observable<C>;
        <A, B, C, D>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
        ): Observable<D>;
        <A, B, C, D, E>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
            op5: OperatorFunction<D, E>,
        ): Observable<E>;
        <A, B, C, D, E, F>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
            op5: OperatorFunction<D, E>,
            op6: OperatorFunction<E, F>,
        ): Observable<F>;
        <A, B, C, D, E, F, G>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
            op5: OperatorFunction<D, E>,
            op6: OperatorFunction<E, F>,
            op7: OperatorFunction<F, G>,
        ): Observable<G>;
        <A, B, C, D, E, F, G, H>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
            op5: OperatorFunction<D, E>,
            op6: OperatorFunction<E, F>,
            op7: OperatorFunction<F, G>,
            op8: OperatorFunction<G, H>,
        ): Observable<H>;
        <A, B, C, D, E, F, G, H, I>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
            op5: OperatorFunction<D, E>,
            op6: OperatorFunction<E, F>,
            op7: OperatorFunction<F, G>,
            op8: OperatorFunction<G, H>,
            op9: OperatorFunction<H, I>,
        ): Observable<I>;
        <A, B, C, D, E, F, G, H, I>(
            op1: OperatorFunction<R, A>,
            op2: OperatorFunction<A, B>,
            op3: OperatorFunction<B, C>,
            op4: OperatorFunction<C, D>,
            op5: OperatorFunction<D, E>,
            op6: OperatorFunction<E, F>,
            op7: OperatorFunction<F, G>,
            op8: OperatorFunction<G, H>,
            op9: OperatorFunction<H, I>,
            ...operations: OperatorFunction<any, any>[],
        ): Observable<unknown>;
    };
    subscribe(observer: Partial<Observer<R>>): Unsubscribable;
}

Type Parameters

  • T
  • R

Hierarchy

  • Subscribable<R>
    • ILoader

Implemented by

Properties

Methods

Properties

next: (value: T) => void
pipe: {
    (): Observable<R>;
    <A>(op1: OperatorFunction<R, A>): Observable<A>;
    <A, B>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
    ): Observable<B>;
    <A, B, C>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
    ): Observable<C>;
    <A, B, C, D>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
    ): Observable<D>;
    <A, B, C, D, E>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
        op5: OperatorFunction<D, E>,
    ): Observable<E>;
    <A, B, C, D, E, F>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
        op5: OperatorFunction<D, E>,
        op6: OperatorFunction<E, F>,
    ): Observable<F>;
    <A, B, C, D, E, F, G>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
        op5: OperatorFunction<D, E>,
        op6: OperatorFunction<E, F>,
        op7: OperatorFunction<F, G>,
    ): Observable<G>;
    <A, B, C, D, E, F, G, H>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
        op5: OperatorFunction<D, E>,
        op6: OperatorFunction<E, F>,
        op7: OperatorFunction<F, G>,
        op8: OperatorFunction<G, H>,
    ): Observable<H>;
    <A, B, C, D, E, F, G, H, I>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
        op5: OperatorFunction<D, E>,
        op6: OperatorFunction<E, F>,
        op7: OperatorFunction<F, G>,
        op8: OperatorFunction<G, H>,
        op9: OperatorFunction<H, I>,
    ): Observable<I>;
    <A, B, C, D, E, F, G, H, I>(
        op1: OperatorFunction<R, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
        op5: OperatorFunction<D, E>,
        op6: OperatorFunction<E, F>,
        op7: OperatorFunction<F, G>,
        op8: OperatorFunction<G, H>,
        op9: OperatorFunction<H, I>,
        ...operations: OperatorFunction<any, any>[],
    ): Observable<unknown>;
}

Methods

  • Parameters

    • observer: Partial<Observer<R>>

    Returns Unsubscribable