Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

  • default

Index

Constructors

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

Properties

#chainInExecution: undefined | symbol
#decoder: default = ...
#maxLength: undefined | null | number
#pubSubState: { isActive: boolean; listeners: { channels: Map<any, any>; patterns: Map<any, any> }; subscribed: number; subscribing: number; unsubscribing: number } = ...

Type declaration

  • isActive: boolean
  • listeners: { channels: Map<any, any>; patterns: Map<any, any> }
    • channels: Map<any, any>
    • patterns: Map<any, any>
  • subscribed: number
  • subscribing: number
  • unsubscribing: number
#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

  • #handlePubSubReply(reply: any): boolean
  • #updatePubSubActiveState(): void
  • flushAll(err: Error): void
  • flushWaitingForReply(err: Error): void
  • onReplyChunk(chunk: 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