Class RpcKernelBaseConnection`Abstract`

Hierarchy

RpcKernelBaseConnection
- RpcKernelConnection

Index

Constructors

Properties

actionClient connections id messageId onClose onCloseResolve? reader replies sessionState timeoutTimers transportWriter writer writerOptions

Methods

clientAddress close controller createMessageBuilder feed handleMessage onMessage sendMessage setTimeout

Constructors

constructor

new RpcKernelBaseConnection(transportWriter: RpcConnectionWriter, connections: RpcKernelConnections): RpcKernelBaseConnection
Parameters
- transportWriter: RpcConnectionWriter
- connections: RpcKernelConnections
Returns RpcKernelBaseConnection
- Defined in packages/rpc/src/server/kernel.ts:200

Properties

`Protected` actionClient

actionClient: RpcActionClient = ...

`Protected` connections

connections: RpcKernelConnections

`Protected` id

id: Uint8Array = ...

`Protected` messageId

messageId: number = 0

`Readonly` onClose

onClose: Promise<void>

`Protected` `Optional` onCloseResolve

onCloseResolve?: Function

`Protected` reader

reader: RpcMessageReader = ...

`Protected` replies

replies: Map<number, ((message: RpcMessage) => void)> = ...

sessionState

sessionState: SessionState = ...

`Protected` timeoutTimers

timeoutTimers: any[] = []

`Protected` transportWriter

transportWriter: RpcConnectionWriter

writer

writer: RpcMessageWriter = ...

writerOptions

writerOptions: RpcMessageWriterOptions = ...

Methods

clientAddress

clientAddress(): undefined | string
Returns undefined | string
- Defined in packages/rpc/src/server/kernel.ts:210

close

close(): void
Returns void
- Defined in packages/rpc/src/server/kernel.ts:230

controller

controller<T>(nameOrDefinition: string | ControllerDefinition<T>, timeoutInSeconds?: number): RemoteController<T>
Type Parameters
- T
Parameters
- nameOrDefinition: string | ControllerDefinition<T>
- timeoutInSeconds: number = 60
Returns RemoteController<T>
- Defined in packages/rpc/src/server/kernel.ts:257

createMessageBuilder

createMessageBuilder(): RpcMessageBuilder
Returns RpcMessageBuilder
- Defined in packages/rpc/src/server/kernel.ts:214

feed

feed(buffer: Uint8Array, bytes?: number): void
Parameters
- buffer: Uint8Array
- Optional bytes: number
Returns void
- Defined in packages/rpc/src/server/kernel.ts:237

handleMessage

handleMessage(message: RpcMessage): void
Parameters
- message: RpcMessage
Returns void
- Defined in packages/rpc/src/server/kernel.ts:241

`Abstract` onMessage

onMessage(message: RpcMessage, response: RpcMessageBuilder): void | Promise<void>
Parameters
- message: RpcMessage
- response: RpcMessageBuilder
Returns void | Promise<void>
- Defined in packages/rpc/src/server/kernel.ts:255

sendMessage

sendMessage<T>(type: number, body?: T, receiveType?: ReceiveType<T>): RpcMessageSubject
Type Parameters
- T
Parameters
- type: number
- Optional body: T
- Optional receiveType: ReceiveType<T>
Returns RpcMessageSubject
- Defined in packages/rpc/src/server/kernel.ts:269

setTimeout

setTimeout(cb: (() => void), timeout: number): any
Creates a regular timer using setTimeout() and automatically cancel it once the connection breaks or server stops.
Parameters
- cb: (() => void)
  - - (): void
    - Returns void
- timeout: number
Returns any
- Defined in packages/rpc/src/server/kernel.ts:221

Generated using TypeDoc