Class RpcMessageSubject

constructor

• new RpcMessageSubject(continuation: (<T>(type: number, body?: T, schema?: ReceiveType<T>) => void), release: (() => void)): RpcMessageSubject

• Parameters

  • continuation: (<T>(type: number, body?: T, schema?: ReceiveType<T>) => void)

    • • <T>(type: number, body?: T, schema?: ReceiveType<T>): void

      • Type Parameters

        • T

        Parameters

        • type: number

        • Optional body: T

        • Optional schema: ReceiveType<T>

        Returns void

  • release: (() => void)

    Releases this subject. It is necessary that eventually every created subject is released, otherwise dramatic performance decrease and memory leak will happen.

    • • (): void

      • Releases this subject. It is necessary that eventually every created subject is released, otherwise dramatic performance decrease and memory leak will happen.

        Returns void

  Returns RpcMessageSubject