ProtocolAdapter class
为流式处理创建协议适配器。
构造函数
| Protocol |
创建协议适配器类的新实例。 |
方法
| on |
当出现取消时，执行接收管道。 |
| on |
当请求传入时执行接收管道。 |
| on |
当响应传入时执行接收管道。 |
| send |
通过附加的请求管理器发送请求。 |
构造函数详细信息
ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)
创建协议适配器类的新实例。
new ProtocolAdapter(requestHandler: RequestHandler, requestManager: RequestManager, sender: PayloadSender, receiver: PayloadReceiver)参数
- requestHandler
- RequestHandler
将处理传入请求的 RequestHandler 。
- requestManager
- RequestManager
将处理传出请求的 RequestManager 。
- sender
- PayloadSender
用于传出请求的 PayloadSender 。
- receiver
- PayloadReceiver
用于传入请求的 PayloadReceiver 。
方法详细信息
onCancelStream(PayloadAssembler)
当出现取消时，执行接收管道。
function onCancelStream(contentStreamAssembler: PayloadAssembler)参数
- contentStreamAssembler
- PayloadAssembler
处理此取消请求面向的传入数据的有效负载汇编程序。
onReceiveRequest(string, IReceiveRequest)
当请求传入时执行接收管道。
function onReceiveRequest(id: string, request: IReceiveRequest): Promise<void>参数
- id
-
string
将为响应创建的资源分配 ID。
- request
- IReceiveRequest
要处理的传入请求。
返回
Promise<void>
onReceiveResponse(string, IReceiveResponse)
当响应传入时执行接收管道。
function onReceiveResponse(id: string, response: IReceiveResponse): Promise<void>参数
- id
-
string
将为响应创建的资源分配 ID。
- response
- IReceiveResponse
对进程的传入响应。
返回
Promise<void>
sendRequest(StreamingRequest)
通过附加的请求管理器发送请求。
function sendRequest(request: StreamingRequest): Promise<IReceiveResponse>参数
- request
- StreamingRequest
要发送的传出请求。
返回
Promise<IReceiveResponse>
对指定请求的响应。