Options
All
  • Public
  • Public/Protected
  • All
Menu

Class RsObservable

Hierarchy

  • RsObservable

Index

Properties

Methods

Properties

Private _subjects

_subjects: Map<string, RsSubject<any>> = new Map<string, RsSubject<any>>()

Private _subscribers

_subscribers: Map<string, RsSubscriber> = new Map<string, RsSubscriber>()

Methods

Private _getOrCreateSubscriber

  • _getOrCreateSubscriber(socketId: string, send: (msg: string) => any): RsSubscriber

  • Parameters

    • socketId: string
    • send: (msg: string) => any
        • (msg: string): any

        • Parameters

          • msg: string

          Returns any

    Returns RsSubscriber

Private _subscribe

  • _subscribe(msg: RsMessageType, send: (msg: string) => any): boolean

  • Parameters

    • msg: RsMessageType
    • send: (msg: string) => any
        • (msg: string): any

        • Parameters

          • msg: string

          Returns any

    Returns boolean

Private _unsubscribe

addSubject

  • addSubject(subjectId: string, subject: RsSubject<any>): boolean

message

  • message(message: any, send: (msg: string) => any): boolean

  • Parameters

    • message: any
    • send: (msg: string) => any
        • (msg: string): any

        • Parameters

          • msg: string

          Returns any

    Returns boolean

removeSubscriber

  • removeSubscriber(socketId: string): boolean

reset

  • reset(): void

Generated using TypeDoc