Class default

Hierarchy

default

Constructors

constructor

new default(maxLength, onShardedChannelMoved): default
Parameters
- maxLength: undefined | null | number
- onShardedChannelMoved: OnShardedChannelMoved
Returns default
- Defined in packages/client/lib/client/commands-queue.ts:99

Properties

`Private` #chainInExecution

#chainInExecution: undefined | symbol

`Private` #decoder

#decoder: default = ...

`Private` `Readonly` #maxLength

#maxLength: undefined | null | number

`Private` `Readonly` #onShardedChannelMoved

#onShardedChannelMoved: OnShardedChannelMoved

`Private` `Readonly` #pubSub

#pubSub: PubSub = ...

`Private` `Readonly` #waitingForReply

#waitingForReply: Yallist<CommandWaitingForReply> = ...

`Private` `Readonly` #waitingToBeSent

#waitingToBeSent: Yallist<CommandWaitingToBeSent> = ...

Accessors

isPubSubActive

get isPubSubActive(): boolean
Returns boolean
- Defined in packages/client/lib/client/commands-queue.ts:49

Methods

`Private` #pushPubSubCommand

#pushPubSubCommand(command): undefined | Promise<void>
Parameters
- command: PubSubCommand
Returns undefined | Promise<void>
- Defined in packages/client/lib/client/commands-queue.ts:197

addCommand

addCommand<T>(args, options?): Promise<T>
Type Parameters
- T = RedisCommandRawReply
Parameters
- args: RedisCommandArguments
- Optional options: QueueCommandOptions
Returns Promise<T>
- Defined in packages/client/lib/client/commands-queue.ts:107

extendPubSubChannelListeners

extendPubSubChannelListeners(type, channel, listeners): undefined | Promise<void>
Parameters
- type: PubSubType
- channel: string
- listeners: ChannelListeners
Returns undefined | Promise<void>
- Defined in packages/client/lib/client/commands-queue.ts:177

extendPubSubListeners

extendPubSubListeners(type, listeners): undefined | Promise<void>
Parameters
- type: PubSubType
- listeners: PubSubTypeListeners
Returns undefined | Promise<void>
- Defined in packages/client/lib/client/commands-queue.ts:187

flushAll

flushAll(err): void
Parameters
- err: Error
Returns void
- Defined in packages/client/lib/client/commands-queue.ts:257

flushWaitingForReply

flushWaitingForReply(err): void
Parameters
- err: Error
Returns void
- Defined in packages/client/lib/client/commands-queue.ts:243

getCommandToSend

getCommandToSend(): undefined | RedisCommandArguments
Returns undefined | RedisCommandArguments
- Defined in packages/client/lib/client/commands-queue.ts:217

getPubSubListeners

getPubSubListeners(type): PubSubTypeListeners
Parameters
- type: PubSubType
Returns PubSubTypeListeners
- Defined in packages/client/lib/client/commands-queue.ts:193

onReplyChunk

onReplyChunk(chunk): void
Parameters
- chunk: Buffer
Returns void
- Defined in packages/client/lib/client/commands-queue.ts:239

resubscribe

resubscribe(): undefined | Promise<any>
Returns undefined | Promise<any>
- Defined in packages/client/lib/client/commands-queue.ts:168

subscribe

subscribe<T>(type, channels, listener, returnBuffers?): undefined | Promise<void>
Type Parameters
- T extends boolean
Parameters
- type: PubSubType
- channels: string | string[]
- listener: PubSubListener<T>
- Optional returnBuffers: T
Returns undefined | Promise<void>
- Defined in packages/client/lib/client/commands-queue.ts:146

unsubscribe

unsubscribe<T>(type, channels?, listener?, returnBuffers?): undefined | Promise<void>
Type Parameters
- T extends boolean
Parameters
- type: PubSubType
- Optional channels: string | string[]
- Optional listener: PubSubListener<T>
- Optional returnBuffers: T
Returns undefined | Promise<void>
- Defined in packages/client/lib/client/commands-queue.ts:157

`Static` `Private` #flushQueue

#flushQueue<T>(queue, err): void
Type Parameters
- T extends CommandWaitingForReply
Parameters
- queue: Yallist<T>
- err: Error
Returns void
- Defined in packages/client/lib/client/commands-queue.ts:36

Generated using TypeDoc