Class RelayTimelineLoader

A loader that can be used to load a timeline in chunks

Hierarchy (View Summary)

  • Loader<number | void, NostrEvent>
    • RelayTimelineLoader

Constructors

constructor

Properties

complete cursor filters id loading$ log observable pipe relay subject subscribe

Accessors

loading

Methods

[observable] next

Constructors

constructor

Properties

complete

complete: boolean = false

if the timeline is complete

cursor

cursor: number = Infinity

current "until" timestamp

filters

filters: TimelessFilter[]

id

id: string = ...

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>;
}

relay

relay: string

Protectedsubject

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

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

Settings

Member Visibility

On This Page

Constructors
Properties
Accessors
Methods