Constructor
new CellPipeline()
Extends
Classes
Members
address :string
- Overrides:
服务器地址。
Type:
- string
kernel :Kernel
- Overrides:
内核对象。
Type:
listenerMap :FastMap.<string, (PipelineListener|function())>
- Overrides:
监听器。
Type:
- FastMap.<string, (PipelineListener|function())>
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:
- Array.<PipelineListener>
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 | 服务器的数据包。 |