ProtocolAdapter class

创建用于流式传输的协议适配器。

构造函数

ProtocolAdapter(RequestHandler, RequestManager, PayloadSender, PayloadReceiver)

创建协议适配器类的新实例。

方法

onCancelStream(PayloadAssembler)

取消时执行接收管道。

onReceiveRequest(string, IReceiveRequest)

在请求传入时执行接收管道。

onReceiveResponse(string, IReceiveResponse)

在响应传入时执行接收管道。

sendRequest(StreamingRequest)

通过附加的请求管理器发送请求。

构造函数详细信息

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>

对指定请求的响应。