Skip to content

@sora-soft/framework


@sora-soft/framework / Connector

Abstract Class: Connector

Defined in: packages/framework/src/lib/rpc/Connector.ts:24

Extended by

Constructors

Constructor

ts
new Connector(options): Connector;

Defined in: packages/framework/src/lib/rpc/Connector.ts:25

Parameters

ParameterType
optionsIConnectorOptions

Returns

Connector

Properties

PropertyModifierTypeDefined in
codec_?protectedCodec<any>packages/framework/src/lib/rpc/Connector.ts:276
lifeCycle_protectedLifeCycle<ConnectorState>packages/framework/src/lib/rpc/Connector.ts:274
session_protectedstring | undefinedpackages/framework/src/lib/rpc/Connector.ts:277
target_?protectedIListenerInfopackages/framework/src/lib/rpc/Connector.ts:275

Accessors

dataSubject

Get Signature

ts
get dataSubject(): Subject<IRawNetPacket>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:266

Returns

Subject<IRawNetPacket>


protocol

Get Signature

ts
get abstract protocol(): string;

Defined in: packages/framework/src/lib/rpc/Connector.ts:55

Returns

string


scope

Get Signature

ts
get scope(): Scope<unknown>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:270

Returns

Scope<unknown>


session

Get Signature

ts
get session(): string | undefined;

Defined in: packages/framework/src/lib/rpc/Connector.ts:254

Returns

string | undefined

Set Signature

ts
set session(value): void;

Defined in: packages/framework/src/lib/rpc/Connector.ts:258

Parameters
ParameterType
valuestring | undefined
Returns

void


state

Get Signature

ts
get state(): ConnectorState;

Defined in: packages/framework/src/lib/rpc/Connector.ts:246

Returns

ConnectorState


stateSubject

Get Signature

ts
get stateSubject(): BehaviorSubject<ConnectorState>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:250

Returns

BehaviorSubject<ConnectorState>


target

Get Signature

ts
get target(): IListenerInfo | undefined;

Defined in: packages/framework/src/lib/rpc/Connector.ts:262

Returns

IListenerInfo | undefined

Methods

connect()

ts
abstract protected connect(target): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:61

Parameters

ParameterType
targetIListenerInfo

Returns

Promise<void>


disablePingPong()

ts
protected disablePingPong(): void;

Defined in: packages/framework/src/lib/rpc/Connector.ts:178

Returns

void


disconnect()

ts
abstract protected disconnect(): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:95

Returns

Promise<void>


enablePingPong()

ts
protected enablePingPong(): void;

Defined in: packages/framework/src/lib/rpc/Connector.ts:147

Returns

void


handleCommand()

ts
protected handleCommand(command, args): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:214

Parameters

ParameterType
commandConnectorCommand
argsunknown

Returns

Promise<void>


handleIncomeMessage()

ts
protected handleIncomeMessage(data): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:187

Parameters

ParameterType
dataIRawNetPacket

Returns

Promise<void>


isAvailable()

ts
abstract isAvailable(): boolean;

Defined in: packages/framework/src/lib/rpc/Connector.ts:54

Returns

boolean


off()

ts
off(): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:96

Returns

Promise<void>


onCodecSelected()

ts
onCodecSelected(code): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:80

Parameters

ParameterType
codestring

Returns

Promise<void>


onPingError()

ts
protected onPingError(err): void;

Defined in: packages/framework/src/lib/rpc/Connector.ts:171

Parameters

ParameterType
errExError

Returns

void


selectCodec()

ts
abstract selectCodec(code): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:79

Parameters

ParameterType
codestring

Returns

Promise<void>


send()

ts
abstract send<RequestPayload>(request): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:122

Type Parameters

Type Parameter
RequestPayload

Parameters

ParameterType
requestIRawNetPacket<RequestPayload>

Returns

Promise<void>


sendCommand()

ts
sendCommand(command, args?): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:131

Parameters

ParameterType
commandConnectorCommand
args?unknown

Returns

Promise<void>


sendNotify()

ts
sendNotify(notify, fromId?): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:125

Parameters

ParameterType
notifyNotify
fromId?string | null

Returns

Promise<void>


sendPing()

ts
protected sendPing(id): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:139

Parameters

ParameterType
idnumber

Returns

Promise<void>


sendPong()

ts
protected sendPong(id): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:143

Parameters

ParameterType
idnumber

Returns

Promise<void>


sendRaw()

ts
abstract sendRaw(request): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:123

Parameters

ParameterType
requestobject

Returns

Promise<void>


start()

ts
start(target, codec): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:62

Parameters

ParameterType
targetIListenerInfo
codecCodec<any>

Returns

Promise<void>


waitForReady()

ts
waitForReady(ttlMs): Promise<void>;

Defined in: packages/framework/src/lib/rpc/Connector.ts:57

Parameters

ParameterType
ttlMsnumber

Returns

Promise<void>

基于 WTFPL 许可发布