CellPipeline

CellPipeline

使用 Cell 进行通信的管道服务。

Constructor

new CellPipeline()

Extends

Classes

CellPipeline

Members

address :string

Overrides:

服务器地址。

Type:
  • string

kernel :Kernel

Overrides:

内核对象。

Type:

listenerMap :FastMap.<string, (PipelineListener|function())>

Overrides:

监听器。

Type:

NAME :string

Cell 管道名称。

Type:
  • string

name :string

Overrides:

名称。

Type:
  • string

nucleus :cell.Nucleus

Cell 内核。

Type:
  • cell.Nucleus

(protected) opened :boolean

Overrides:

是否执行过开启操作。

Type:
  • boolean

port :number

Overrides:

服务器端口。

Type:
  • number

responseMap :OrderMap

保存异步返回消息的状态信息的映射。

Type:

responseTimeout :number

应答超时时长。单位:毫秒。

Type:
  • number

responseTimer :number

应答超时控制定时器。

Type:
  • number

stateListenerList :Array.<PipelineListener>

Overrides:

状态监听器。

Type:

talkListener :CellTalkListener

监听器。

Type:

timerPeriod :number

定时器周期。单位:毫秒。

Type:
  • number

tokenCode :string

Overrides:

有效的令牌编码。

Type:
  • string

Methods

addListener(destination, listener)

Overrides:

添加监听器。

Parameters:
Name Type Description
destination string

指定监听的目标或识别串。

listener PipelineListener

指定通道监听器。

addStateListener(listener)

Overrides:

添加状态监听器。

Parameters:
Name Type Description
listener PipelineListener

指定通道监听器。

close()

Overrides:

关闭数据通道。

convertPacketToPrimitive(packet) → {cell.ActionDialect}

将 Packet 转为 ActionDialect 格式。

Parameters:
Name Type Description
packet Packet

数据报文封装实体。

Returns:

返回 ActionDialect 实例。

Type
cell.ActionDialect

convertPrimitiveToPacket(primitive) → {Packet}

将 Primitive 转为 Packet 格式。

Parameters:
Name Type Description
primitive cell.Primitive

Cell 的 Primitive 实例。

Returns:

返回 Packet 实例。

Type
Packet

(protected) getListeners(destination) → {Array.<PipelineListener>}

Overrides:

获取目标的监听器列表。

Parameters:
Name Type Description
destination string
Returns:

返回目标的监听器列表。

Type
Array.<PipelineListener>

getName() → {string}

Overrides:

获取通道名称。

Returns:

返回通道名称。

Type
string

isReady() → {boolean}

Overrides:

数据通道是否就绪。

Returns:

如果就绪返回 true

Type
boolean

open()

Overrides:

启动数据通道。

removeListener(destination, listener)

Overrides:

移除监听器。

Parameters:
Name Type Description
destination string

指定监听的目标或识别串。

listener PipelineListener

指定通道监听器。

removeStateListener(listener)

Overrides:

移除状态监听器。

Parameters:
Name Type Description
listener PipelineListener

指定通道监听器。

send(destination, packet, handleResponseopt)

Overrides:

发送数据。

Parameters:
Name Type Attributes Description
destination string

指定通道的发送目标或接收端识别串。

packet Packet

指定待发送的数据包。

handleResponse ResponseCallback <optional>

本次数据发送对应的应答回调。

setRemoteAddress(address, portopt)

Overrides:

设置服务的地址和端口。

Parameters:
Name Type Attributes Description
address string

服务器访问地址。

port number <optional>

服务器访问端口。

setTokenCode(tokenCode)

Overrides:

设置令牌代码。

Parameters:
Name Type Description
tokenCode string

(protected) touchCallback(source, packet, callback)

Overrides:

触发对应请求的应答。

Parameters:
Name Type Description
source string

来自通道的描述串。

packet Packet

来自服务器的数据包。

callback ResponseCallback

回调函数。

(protected) triggerListened(speaker, cellet, primitive)

触发消息接收处理。

Parameters:
Name Type Description
speaker cell.Speaker
cellet string
primitive cell.Primitive

(protected) triggerListeners(source, packet)

Overrides:

触发来自服务器的数据回调。

Parameters:
Name Type Description
source string

通道的描述串。

packet Packet

服务器的数据包。