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>
对指定请求的响应。