Class RpcMessageReader

Hierarchy

RpcMessageReader

Index

Constructors

Properties

bufferReader chunkAcks chunks onChunk? onMessage progress

Methods

feed gotMessage onChunkAck registerProgress

Constructors

constructor

new RpcMessageReader(onMessage: ((response: RpcMessage) => void), onChunk?: ((id: number) => void)): RpcMessageReader
Parameters
- onMessage: ((response: RpcMessage) => void)
  - - (response: RpcMessage): void
    - Parameters
      
      response: RpcMessage
      
      Returns void
- Optional onChunk: ((id: number) => void)
  - - (id: number): void
    - Parameters
      
      id: number
      
      Returns void
Returns RpcMessageReader
- Defined in packages/rpc/src/protocol.ts:451

Properties

`Protected` bufferReader

bufferReader: RpcBufferReader = ...

`Protected` chunkAcks

chunkAcks: Map<number, Function> = ...

`Protected` chunks

chunks: Map<number, {
buffers: Uint8Array[];
loaded: number;
}> = ...

`Protected` `Optional` `Readonly` onChunk

onChunk?: ((id: number) => void)

Type declaration

- (id: number): void
- Parameters
  - id: number
  Returns void

`Protected` `Readonly` onMessage

onMessage: ((response: RpcMessage) => void)

Type declaration

- (response: RpcMessage): void
- Parameters
  - response: RpcMessage
  Returns void

`Protected` progress

progress: Map<number, SingleProgress> = ...

Methods

feed

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

`Protected` gotMessage

gotMessage(buffer: Uint8Array): void
Parameters
- buffer: Uint8Array
Returns void
- Defined in packages/rpc/src/protocol.ts:469

onChunkAck

onChunkAck(id: number, callback: Function): void
Parameters
- id: number
- callback: Function
Returns void
- Defined in packages/rpc/src/protocol.ts:457

registerProgress

registerProgress(id: number, progress: SingleProgress): void
Parameters
- id: number
- progress: SingleProgress
Returns void
- Defined in packages/rpc/src/protocol.ts:461

Generated using TypeDoc