Class AntidoteConnection

Hierarchy

AntidoteConnection

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new AntidoteConnection(port: number, host: string): AntidoteConnection

- Defined in antidoteConnection.ts:21
Parameters
- port: number
- host: string
Returns AntidoteConnection

Properties

Private buffer

buffer: ByteBuffer = new ByteBuffer()

Private host

host: string | undefined

Private port

port: number

requestTimeoutMs

requestTimeoutMs: number = 1000

Private requests

requests: ApbRequest[] = []

Private socket

socket: Socket | undefined

Methods

close

close(): void

- Defined in antidoteConnection.ts:43
Returns void

Private handleError

handleError(errorCode: number, errorMsg: string): void

- Defined in antidoteConnection.ts:127
Parameters
- errorCode: number
- errorMsg: string
Returns void

Private handleResponse

handleResponse(code: number, decoded: any): void

- Defined in antidoteConnection.ts:118
Parameters
- code: number
- decoded: any
Returns void

Private invalidateSocket

invalidateSocket(err: Error): void

- Defined in antidoteConnection.ts:154
Parameters
- err: Error
Returns void

Private onClose

onClose(hasError: boolean): void

- Defined in antidoteConnection.ts:138
Parameters
- hasError: boolean
Returns void

Private onConnect

onConnect(): void

- Defined in antidoteConnection.ts:51
Returns void

Private onData

onData(data: Buffer): void

- Defined in antidoteConnection.ts:55
Parameters
- data: Buffer
Returns void

Private onError

onError(err: Error): void

- Defined in antidoteConnection.ts:142
Parameters
- err: Error
Returns void

Private onRequestTimeout

onRequestTimeout(): void

- Defined in antidoteConnection.ts:150
Returns void

Private onTimeout

onTimeout(): void

- Defined in antidoteConnection.ts:146
Returns void

Private readMessagesFromBuffer

readMessagesFromBuffer(): void

- Defined in antidoteConnection.ts:61
Returns void

Private reconnect

reconnect(): void

- Defined in antidoteConnection.ts:29
Returns void

Private reject

reject(req: ApbRequest, err: Error): void

- Defined in antidoteConnection.ts:172
Parameters
- req: ApbRequest
- err: Error
Returns void

Private rejectPending

rejectPending(err: Error): void

- Defined in antidoteConnection.ts:164
rejects all requests, which are still open

Parameters
- err: Error
Returns void

Private resolve

resolve(req: ApbRequest, response: any): void

- Defined in antidoteConnection.ts:177
Parameters
- req: ApbRequest
- response: any
Returns void

sendRequest

sendRequest(messageCode: number, encodedMessage: ArrayBuffer): Promise<any>

- Defined in antidoteConnection.ts:182
Parameters
- messageCode: number
- encodedMessage: ArrayBuffer
Returns Promise<any>

Generated using TypeDoc