Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

  • default

Index

Constructors

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

Properties

#chainInExecution: undefined | symbol
#maxLength: undefined | null | number
#parser: any = ...
#pubSubState: undefined | PubSubState
#waitingForReply: Yallist<CommandWaitingForReply> = ...
#waitingToBeSent: Yallist<CommandWaitingToBeSent> = ...
#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

  • #initiatePubSubState(): PubSubState
  • #setReturnBuffers(): void
  • #shiftWaitingForReply(): CommandWaitingForReply
  • flushAll(err: Error): void
  • flushWaitingForReply(err: Error): void
  • parseResponse(data: Buffer): void
  • resubscribe(): undefined | Promise<any>
  • #emitPubSubMessage(listenersMap: PubSubListenersMap, message: Buffer, channel: Buffer, pattern?: Buffer): void
  • #flushQueue<T>(queue: Yallist<T>, err: Error): void

Generated using TypeDoc