Class RPC

Hierarchy

Stream
- RPC

Index

Constructors

constructor

Properties

Methods

Object literals

_options

Constructors

constructor

new RPC(options?: Options): RPC

Overrides Stream.__constructor
- Defined in rpt.ts:177
Parameters
- Optional options: Options
Returns RPC

Properties

Private _active

_active: number = 0

Protected _end

_end: endCallback

Private _pending

_pending: any

Private _queue

_queue: Uint8Array

Private _statechange

_statechange: function

Type declaration

- (): void
- Returns void

Protected _write

_write: dataCallback

isClosed

isClosed: boolean

isClosing

isClosing: boolean

isOpening

isOpening: boolean

isRunning

isRunning: boolean

readable

readable: boolean

state

state: State

writable

writable: boolean

Methods

Private addRef

addRef(): void

- Defined in rpt.ts:334
Returns void

catch

catch(reject: any): RPC

Overrides Stream.catch
- Defined in rpt.ts:272
Parameters
- reject: any
Returns RPC

close

close(callback: notifyCallback): RPC

Overrides Stream.close
- Defined in rpt.ts:292
Parameters
- callback: notifyCallback
Returns RPC

Private create

create(id: number, callback: rpc_packet_event): number

- Defined in rpt.ts:394
Parameters
- id: number
- callback: rpc_packet_event
Returns number

data

data(callback: dataCallback): RPC

Overrides Stream.data
- Defined in rpt.ts:312
Parameters
- callback: dataCallback
Returns RPC

Private decode

decode(packet: rpc_packet_t): any

- Defined in rpt.ts:443
Parameters
- packet: rpc_packet_t
Returns any

drain

drain(callback: notifyCallback): RPC

Overrides Stream.drain
- Defined in rpt.ts:307
Parameters
- callback: notifyCallback
Returns RPC

end

end(arg?: any): RPC

Overrides Stream.end
- Defined in rpt.ts:317
Parameters
- Optional arg: any
Returns RPC

exec

exec(event: string, data?: any): Promise<any>

- Defined in rpt.ts:244
Parameters
- event: string
- Optional data: any
Returns Promise<any>

finally

finally(callback: any): RPC

Overrides Stream.finally
- Defined in rpt.ts:277
Parameters
- callback: any
Returns RPC

Private handlePacket

handlePacket(packet: rpc_packet_t): void

- Defined in rpt.ts:346
Parameters
- packet: rpc_packet_t
Returns void

off

off(event: string): RPC

- Defined in rpt.ts:262
Parameters
- event: string
Returns RPC

on

on(event: string, callback: function): RPC

- Defined in rpt.ts:221
Parameters
- event: string
- callback: function
  - - (resolve: resolveCallback, reject: rejectCallback, data?: any): void
    - Parameters
      - resolve: resolveCallback
      - reject: rejectCallback
      - Optional data: any
      Returns void
Returns RPC

open

open(callback: notifyCallback): RPC

Overrides Stream.open
- Defined in rpt.ts:287
Parameters
- callback: notifyCallback
Returns RPC

Private parse

parse(chunk: any): Error

- Defined in rpt.ts:356
Parameters
- chunk: any
Returns Error

pause

pause(callback: notifyCallback): RPC

Overrides Stream.pause
- Defined in rpt.ts:297
Parameters
- callback: notifyCallback
Returns RPC

pipe

pipe(dst: Stream): Stream

Inherited from Stream.pipe
- Defined in /Users/villemolsa/Documents/rpc-prototype/node_modules/stream-ng/dist/stream-ng.d.ts:63
Parameters
- dst: Stream
Returns Stream

push

push(chunk: any, callback?: errorCallback): RPC

Overrides Stream.push
- Defined in rpt.ts:327
Parameters
- chunk: any
- Optional callback: errorCallback
Returns RPC

Private remove

remove(id: number): void

- Defined in rpt.ts:399
Parameters
- id: number
Returns void

Private removeRef

removeRef(): void

- Defined in rpt.ts:338
Returns void

resume

resume(callback: notifyCallback): RPC

Overrides Stream.resume
- Defined in rpt.ts:302
Parameters
- callback: notifyCallback
Returns RPC

Private send

send(packet: rpc_packet_t, callback?: rpc_packet_event, data?: any): Error | RPC

- Defined in rpt.ts:403
Parameters
- packet: rpc_packet_t
- Optional callback: rpc_packet_event
- Optional data: any
Returns Error | RPC

setState

setState(state: State): RPC

Overrides Stream.setState
- Defined in rpt.ts:282
Parameters
- state: State
Returns RPC

then

then(resolve: any, reject?: any): RPC

Overrides Stream.then
- Defined in rpt.ts:267
Parameters
- resolve: any
- Optional reject: any
Returns RPC

Private uniqueId

uniqueId(event: rpc_event_t): number

- Defined in rpt.ts:384
Parameters
- event: rpc_event_t
Returns number

write

write(chunk: any, callback?: errorCallback): RPC

Overrides Stream.write
- Defined in rpt.ts:322
Parameters
- chunk: any
- Optional callback: errorCallback
Returns RPC

Static Private Compile

Compile(packet: rpc_packet_t): boolean

- Defined in rpt.ts:619
Parameters
- packet: rpc_packet_t
Returns boolean

Static Private Decode

Decode(encoded: rpc_encode_t): rpc_decode_t

- Defined in rpt.ts:527
Parameters
- encoded: rpc_encode_t
Returns rpc_decode_t

Static Private Dump

Dump(packet: rpc_packet_t): any

- Defined in rpt.ts:635
Parameters
- packet: rpc_packet_t
Returns any

Static Private Encode

Encode(context: any, options: Options): rpc_encode_t

- Defined in rpt.ts:466
Parameters
- context: any
- options: Options
Returns rpc_encode_t

Static Private Parse

Parse(packet: rpc_packet_t): boolean

- Defined in rpt.ts:576
Parameters
- packet: rpc_packet_t
Returns boolean

Static Private setMask

setMask(event: rpc_event_t, value?: number): number

- Defined in rpt.ts:462
Parameters
- event: rpc_event_t
- Default value value: number = ((Math.random() * 0xffffff) >>> 0)
Returns number

Object literals

Private _options

_options: object

deflateThreshold

deflateThreshold: number = 1024

ipc

ipc: boolean = false

Generated using TypeDoc