Class TimelineLoader

A multi-relay timeline loader that can be used to load a timeline from multiple relays

Hierarchy (View Summary)

  • Loader<number | undefined, NostrEvent>
    • TimelineLoader

Constructors

constructor

Properties

cache? id loaders loading$ log observable pipe requests subject subscribe

Accessors

loading

Methods

[observable] next simpleFilterMap

Constructors

constructor

Properties

Protected Optionalcache

cache?: CacheTimelineLoader

id

id: string = ...

Protectedloaders

loaders: Map<string, RelayTimelineLoader>

loading$

loading$: BehaviorSubject<boolean> = ...

Protectedlog

log: Debugger = ...

observable

observable: Observable<Event>

pipe

pipe: {
    (): Observable<Event>;
    <A>(op1: OperatorFunction<Event, A>): Observable<A>;
    <A, B>(
        op1: OperatorFunction<Event, A>,
        op2: OperatorFunction<A, B>,
    ): Observable<B>;
    <A, B, C>(
        op1: OperatorFunction<Event, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
    ): Observable<C>;
    <A, B, C, D>(
        op1: OperatorFunction<Event, A>,
        op2: OperatorFunction<A, B>,
        op3: OperatorFunction<B, C>,
        op4: OperatorFunction<C, D>,
    ): Observable<D>;
    <A, B, C, D, E>(
        op1: OperatorFunction<Event, 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<Event, 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<Event, 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<Event, 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<Event, 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<Event, 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>;
}

requests

requests: RelayFilterMap<TimelessFilter>

Protectedsubject

subject: Subject<undefined | number> = ...

subscribe

subscribe: {
    (
        observerOrNext?: Partial<Observer<Event>> | (value: Event) => void,
    ): Subscription;
    (
        next?: null | (value: Event) => void,
        error?: null | (error: any) => void,
        complete?: null | () => void,
    ): Subscription;
}

Type declaration

    • (
          observerOrNext?: Partial<Observer<Event>> | (value: Event) => void,
      ): Subscription

    • Parameters

      • OptionalobserverOrNext: Partial<Observer<Event>> | (value: Event) => void

      Returns Subscription

    • (
          next?: null | (value: Event) => void,
          error?: null | (error: any) => void,
          complete?: null | () => void,
      ): Subscription

    • Parameters

      • Optionalnext: null | (value: Event) => void
      • Optionalerror: null | (error: any) => void
      • Optionalcomplete: null | () => void

      Returns Subscription

      Deprecated

      Instead of passing separate callback arguments, use an observer argument. Signatures taking separate callback arguments will be removed in v8. Details: https://rxjs.dev/deprecations/subscribe-arguments

Accessors

loading

Methods

[observable]

next

StaticsimpleFilterMap

Settings

Member Visibility

On This Page

Constructors
Properties
Accessors
Methods