Class CacheTimelineLoader

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

Hierarchy (view full)

  • Loader<number | void, EventPacket>
    • CacheTimelineLoader

Constructors

constructor

Properties

cursor eose filters id loading$ log observable pipe subject subscribe

Accessors

loading

Methods

[observable] next

Constructors

constructor

Properties

cursor

cursor: number = Infinity

current "until" timestamp

eose

eose: boolean = false

set to true when 0 events are returned from last batch

filters

filters: TimelessFilter[]

id

id: string = ...

loading$

loading$: BehaviorSubject<boolean> = ...

Protectedlog

log: Debugger = ...

observable

observable: Observable<EventPacket>

pipe

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

Protectedsubject

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

subscribe

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

Type declaration

    • (observerOrNext?): Subscription

    • Parameters

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

      Returns Subscription

    • (next?, error?, complete?): Subscription

    • Parameters

      • Optionalnext: null | ((value: EventPacket) => 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