com.huaweicloud.pangu.dev.sdk.client

Class StreamHelper

java.lang.Object

com.huaweicloud.pangu.dev.sdk.client.StreamHelper

public class StreamHelper
extends Object

抽取和流式处理相关的公共方法

Since:

2023.12.12

Constructor Summary

Constructors

Constructor and Description
StreamHelper()

Method Summary

Modifier and Type	Method and Description
static PanguChatResp	getAllRespFromChunk(List<PanguChatChunk> panguChatChunks)
static org.apache.http.nio.client.methods.AsyncCharConsumer<org.apache.http.HttpResponse>	getAsyncConsumer(StreamCallBack streamCallBack, String callBackId, List<PanguChatChunk> panguChatChunks)
static org.apache.http.nio.client.methods.AsyncCharConsumer<org.apache.http.HttpResponse>	getAsyncConsumer(StreamCallBack streamCallBack, String callBackId, List<PanguChatChunk> panguChatChunks, List<String> eventChunks)
static org.apache.http.concurrent.FutureCallback<org.apache.http.HttpResponse>	getCallBack(StreamCallBack streamCallBack, String callBackId, org.apache.http.client.methods.HttpPost httpPost)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamHelper

public StreamHelper()

Method Detail

getCallBack

public static org.apache.http.concurrent.FutureCallback<org.apache.http.HttpResponse> getCallBack(StreamCallBack streamCallBack,
                                                                                                  String callBackId,
                                                                                                  org.apache.http.client.methods.HttpPost httpPost)

getAllRespFromChunk

public static PanguChatResp getAllRespFromChunk(List<PanguChatChunk> panguChatChunks)

getAsyncConsumer

public static org.apache.http.nio.client.methods.AsyncCharConsumer<org.apache.http.HttpResponse> getAsyncConsumer(StreamCallBack streamCallBack,
                                                                                                                  String callBackId,
                                                                                                                  List<PanguChatChunk> panguChatChunks)

getAsyncConsumer

public static org.apache.http.nio.client.methods.AsyncCharConsumer<org.apache.http.HttpResponse> getAsyncConsumer(StreamCallBack streamCallBack,
                                                                                                                  String callBackId,
                                                                                                                  List<PanguChatChunk> panguChatChunks,
                                                                                                                  List<String> eventChunks)