Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

  • default

Index

Constructors

constructor

  • new default(maxLength: undefined | null | number): default

Properties

Private #chainInExecution

#chainInExecution: undefined | symbol

Private Readonly #maxLength

#maxLength: undefined | null | number

Private Readonly #parser

#parser: any = ...

Private #pubSubState

#pubSubState: undefined | PubSubState

Private Readonly #waitingForReply

#waitingForReply: Yallist<CommandWaitingForReply> = ...

Private Readonly #waitingToBeSent

#waitingToBeSent: Yallist<CommandWaitingToBeSent> = ...

Static Private Readonly #PUB_SUB_MESSAGES

#PUB_SUB_MESSAGES: { message: Buffer; pMessage: Buffer; pSubscribe: Buffer; pUnsubscribe: Buffer; subscribe: Buffer; unsubscribe: Buffer } = ...

Type declaration

  • message: Buffer
  • pMessage: Buffer
  • pSubscribe: Buffer
  • pUnsubscribe: Buffer
  • subscribe: Buffer
  • unsubscribe: Buffer

Methods

Private #initiatePubSubState

  • #initiatePubSubState(): PubSubState

Private #pushPubSubCommand

Private #shiftWaitingForReply

  • #shiftWaitingForReply(): CommandWaitingForReply

addCommand

flushAll

  • flushAll(err: Error): void

flushWaitingForReply

  • flushWaitingForReply(err: Error): void

getCommandToSend

parseResponse

  • parseResponse(data: Buffer): void

resubscribe

  • resubscribe(): undefined | Promise<any>

subscribe

  • subscribe<T>(command: PubSubSubscribeCommands, channels: PubSubArgumentTypes | PubSubArgumentTypes[], listener: PubSubListener<T, T extends true ? Buffer : string>, bufferMode?: T): Promise<void>

unsubscribe

Static Private #emitPubSubMessage

  • #emitPubSubMessage(listenersMap: PubSubListenersMap, message: Buffer, channel: Buffer, pattern?: Buffer): void

Static Private #flushQueue

  • #flushQueue<T>(queue: Yallist<T>, err: Error): void

Generated using TypeDoc