Options
All
  • Public
  • Public/Protected
  • All
Menu

Class RPCProtocolImpl

Hierarchy

  • RPCProtocolImpl

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

  • new RPCProtocolImpl(connection: MessageConnection, transformations?: { replacer?: (key: undefined | string, value: any) => any; reviver?: (key: undefined | string, value: any) => any }): RPCProtocolImpl

  • Parameters

    • connection: MessageConnection
    • Optional transformations: { replacer?: (key: undefined | string, value: any) => any; reviver?: (key: undefined | string, value: any) => any }
      • Optional replacer?: (key: undefined | string, value: any) => any
          • (key: undefined | string, value: any): any

          • Parameters

            • key: undefined | string
            • value: any

            Returns any

      • Optional reviver?: (key: undefined | string, value: any) => any
          • (key: undefined | string, value: any): any

          • Parameters

            • key: undefined | string
            • value: any

            Returns any

    Returns RPCProtocolImpl

Properties

Private Readonly cancellationTokenSources

cancellationTokenSources: Map<string, CancellationTokenSource> = ...

Private lastMessageId

lastMessageId: number = 0

Private Readonly locals

locals: Map<string, any> = ...

Private Readonly multiplexer

multiplexer: RPCMultiplexer

Private Readonly pendingRPCReplies

pendingRPCReplies: Map<string, Deferred<any>> = ...

Private Readonly proxies

proxies: Map<string, any> = ...

Private replacer

replacer: (key: undefined | string, value: any) => any

Type declaration

    • (key: undefined | string, value: any): any

    • Parameters

      • key: undefined | string
      • value: any

      Returns any

Private reviver

reviver: (key: undefined | string, value: any) => any

Type declaration

    • (key: undefined | string, value: any): any

    • Parameters

      • key: undefined | string
      • value: any

      Returns any

Private Readonly toDispose

toDispose: DisposableCollection = ...

Accessors

Private isDisposed

  • get isDisposed(): boolean

Methods

Private cancel

  • cancel(req: string): string

Private createProxy

  • createProxy<T>(proxyId: string): T

dispose

  • dispose(): void

Private doInvokeHandler

  • doInvokeHandler(proxyId: string, methodName: string, args: any[]): any

getProxy

Private invokeHandler

  • invokeHandler(proxyId: string, methodName: string, args: any[]): Promise<any>

Private receiveCancel

  • receiveCancel(msg: CancelMessage): void

Private receiveOneMessage

  • receiveOneMessage(rawmsg: string): void

Private receiveReply

  • receiveReply(msg: ReplyMessage): void

Private receiveReplyErr

  • receiveReplyErr(msg: ReplyErrMessage): void

Private receiveRequest

  • receiveRequest(msg: RequestMessage): void

Private remoteCall

  • remoteCall(proxyId: string, methodName: string, args: any[]): Promise<any>

Private replyErr

  • replyErr(req: string, err: any): string

Private replyOK

  • replyOK(req: string, res: any): string

Private request

  • request(req: string, rpcId: string, method: string, args: any[]): string

set