Class ListSourceMultiplexer

Hierarchy

ListSourceMultiplexer

Constructors

constructor

new ListSourceMultiplexer(sources: ISourceWithMeta[]): ListSourceMultiplexer
Parameters
- sources: ISourceWithMeta[]
Returns ListSourceMultiplexer
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:49

Properties

`Private` _guaranteed

_guaranteed: number = 0

`Private` _guaranteedSegment

_guaranteedSegment: IMessageWithSource[] = []

`Private` _minReadingSize

_minReadingSize: number = 10

`Protected` newMessagesSubscriptions

newMessagesSubscriptions: Set<{
callback: (() => void);
name: string;
}> = ...

`Private` requestCriticalSection

requestCriticalSection: CriticalSection = ...

`Private` sourceIndex

sourceIndex: Map<IListSource, number> = ...

`Private` sources

sources: ListWrappedSource[] = []

Accessors

guaranteedSegment

get guaranteedSegment(): IMessageWithSource[]
Returns IMessageWithSource[]
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:57

newMessagesCount

get newMessagesCount(): number
Returns number
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:61

newMessagesNonSorted

get newMessagesNonSorted(): IMessageWithSource[]
Returns IMessageWithSource[]
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:65

readToBottom

get readToBottom(): boolean
Returns boolean
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:53

Methods

`Private` addSource

addSource(source: IListSource, meta?: any): void
Parameters
- source: IListSource
- Optional meta: any
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:81

`Private` compare

compare(a: {
    msg: IMessage<any>;
    source: IListSource;
}, b: {
    msg: IMessage<any>;
    source: IListSource;
}): number
Parameters
- a: {
  msg: IMessage<any>;
  source: IListSource;
  }
  - msg: IMessage<any>
  - source: IListSource
- b: {
  msg: IMessage<any>;
  source: IListSource;
  }
  - msg: IMessage<any>
  - source: IListSource
Returns number
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:100

connect

connect(subscriptionName: string, newMessagesCallback: (() => void)): Promise<{
dispose: (() => void);
request: ((...args: [before: IMessage<any>, limit: number]) => Promise<void>);
}>
Parameters
- subscriptionName: string
- newMessagesCallback: (() => void)
  - - (): void
    - Returns void
Returns Promise<{
dispose: (() => void);
request: ((...args: [before: IMessage<any>, limit: number]) => Promise<void>);
}>
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:274

`Private` connectSources

connectSources(): Promise<void>
Returns Promise<void>
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:133

`Private` disconnectSources

disconnectSources(): void
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:163

drainNewMessages

drainNewMessages(): Promise<void>
Returns Promise<void>
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:218

`Private` handleNewMessages

handleNewMessages(s: ListWrappedSource): void
Parameters
- s: ListWrappedSource
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:118

`Private` log

log(...args: any[]): void
Parameters
- Rest ...args: any[]
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:114

`Private` recalcGuaranteed

recalcGuaranteed(): void
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:167

`Private` recalcNewMessages

recalcNewMessages(): void
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:177

`Private` recalcSegments

recalcSegments(): void
Returns void
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:188

`Private` request

request(name: string, before: IMessage<any>, limit?: number): Promise<void>
Parameters
- name: string
- before: IMessage<any>
- limit: number = 10
Returns Promise<void>
- Defined in src/messages-list/high-level/ListSourceMultiplexer.ts:226

Generated using TypeDoc