Class ChannelService

Interface for channel service

Implements

IChannelService

Index

Constructors

Methods

push pushParallel pushSequence subscribe waitForEvent

Constructors

constructor

new ChannelService(): ChannelService
Returns ChannelService

Methods

push

push<T = unknown>(
    channel: Channel,
    event: string,
    payload?: object,
    options?: PushOptions,
): Promise<T>
Push a message to a channel and wait for response
Type Parameters
- T = unknown
Parameters
- channel: Channel
- event: string
- Optionalpayload: object
- Optionaloptions: PushOptions
Returns Promise<T>
Implementation of IChannelService.push
- Defined in packages/core/dist/services/ChannelService.d.ts:11

pushParallel

pushParallel(
channel: Channel,
operations: BatchPushOperation[],
): Promise<PushResult<unknown>[]>
Push multiple operations in parallel
Parameters
- channel: Channel
- operations: BatchPushOperation[]
Returns Promise<PushResult<unknown>[]>
Implementation of IChannelService.pushParallel
- Defined in packages/core/dist/services/ChannelService.d.ts:13

pushSequence

pushSequence(
channel: Channel,
operations: BatchPushOperation[],
): Promise<PushResult<unknown>[]>
Push multiple operations sequentially
Parameters
- channel: Channel
- operations: BatchPushOperation[]
Returns Promise<PushResult<unknown>[]>
Implementation of IChannelService.pushSequence
- Defined in packages/core/dist/services/ChannelService.d.ts:12

subscribe(
    channel: Channel,
    event: string,
    handler: (payload: unknown) => void,
): () => void
Subscribe to channel events
Parameters
- channel: Channel
- event: string
- handler: (payload: unknown) => void
Returns () => void
Implementation of IChannelService.subscribe
- Defined in packages/core/dist/services/ChannelService.d.ts:14

waitForEvent

waitForEvent<T = unknown>(
    channel: Channel,
    event: string,
    timeoutMs?: number,
): Promise<T>
Wait for a specific event on a channel
Type Parameters
- T = unknown
Parameters
- channel: Channel
- event: string
- OptionaltimeoutMs: number
Returns Promise<T>
Implementation of IChannelService.waitForEvent
- Defined in packages/core/dist/services/ChannelService.d.ts:15