Class BufferPushScheduler

Hierarchy

BufferPushScheduler

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new BufferPushScheduler(app: Application, opts?: BufferPushSchedulerOptions): BufferPushScheduler

- Defined in pushSchedulers/buffer.ts:18
Parameters
- app: Application
- Optional opts: BufferPushSchedulerOptions
Returns BufferPushScheduler

Properties

app

app: Application

flushInterval

flushInterval: number

sessions

sessions: object

Type declaration

[sid: number]: Session[]

tid

tid: Timer = null

Methods

doBatchPush

doBatchPush(msg: any, recvs: SID[]): void

- Defined in pushSchedulers/buffer.ts:114
Parameters
- msg: any
- recvs: SID[]
Returns void

doBroadcast

doBroadcast(msg: any, opts: BroadcastOptions): void

- Defined in pushSchedulers/buffer.ts:83
Parameters
- msg: any
- opts: BroadcastOptions
Returns void

enqueue

enqueue(session: Session, msg: any): void

- Defined in pushSchedulers/buffer.ts:128
Parameters
- session: Session
- msg: any
Returns void

flush

flush(): void

- Defined in pushSchedulers/buffer.ts:59
Returns void

onClose

onClose(session: Session): void

- Defined in pushSchedulers/buffer.ts:140
Parameters
- session: Session
Returns void

schedule

schedule(reqId: number, route: string, msg: any, recvs: SID[], opts: ScheduleOptions, cb: function): void

- Defined in pushSchedulers/buffer.ts:42
Parameters
- reqId: number
- route: string
- msg: any
- recvs: SID[]
- opts: ScheduleOptions
- cb: function
  - - (): void
    - Returns void
Returns void

start

start(): Promise<void>

- Defined in pushSchedulers/buffer.ts:28
Returns Promise<void>

stop

stop(): Promise<void>

- Defined in pushSchedulers/buffer.ts:33
Returns Promise<void>