com.alibaba.dashscope.protocol.okhttp

类 OkHttpWebSocketClient

java.lang.Object

okhttp3.WebSocketListener

com.alibaba.dashscope.protocol.okhttp.OkHttpWebSocketClient

所有已实现的接口:

FullDuplexClient, HalfDuplexClient

直接已知子类:

OkHttpWebSocketClientForAudio

public class OkHttpWebSocketClient
extends okhttp3.WebSocketListener
implements HalfDuplexClient, FullDuplexClient

字段概要

字段

限定符和类型	字段和说明
protected AtomicBoolean	isFirstMessage
protected io.reactivex.FlowableEmitter<DashScopeResult>	responseEmitter

构造器概要

构造器

构造器和说明
OkHttpWebSocketClient(okhttp3.OkHttpClient client, boolean passTaskStarted)

方法概要

限定符和类型	方法和说明
void	cancel()
boolean	close(int code, String reason)
io.reactivex.Flowable<DashScopeResult>	duplex(FullDuplexRequest req)
void	duplex(FullDuplexRequest req, ResultCallback<DashScopeResult> callback)
void	onClosed(okhttp3.WebSocket webSocket, int code, String reason)
void	onClosing(okhttp3.WebSocket webSocket, int code, String reason)
void	onFailure(okhttp3.WebSocket webSocket, Throwable t, okhttp3.Response response)
void	onMessage(okhttp3.WebSocket webSocket, okio.ByteString bytes)
void	onMessage(okhttp3.WebSocket webSocket, String text)
void	onOpen(okhttp3.WebSocket webSocket, okhttp3.Response response)
DashScopeResult	send(HalfDuplexRequest req) Blocking send http request and get the response body.
void	send(HalfDuplexRequest req, ResultCallback<DashScopeResult> callback)
protected void	sendBinaryWithRetry(String apiKey, boolean isSecurityCheck, okio.ByteString message, String workspace, Map<String,String> customHeaders, String baseWebSocketUrl)
protected CompletableFuture<Void>	sendStreamRequest(FullDuplexRequest req)
protected void	sendTextWithRetry(String apiKey, boolean isSecurityCheck, String message, String workspace, Map<String,String> customHeaders, String baseWebSocketUrl)
DashScopeResult	streamIn(FullDuplexRequest req)
void	streamIn(FullDuplexRequest req, ResultCallback<DashScopeResult> callback)
io.reactivex.Flowable<DashScopeResult>	streamOut(HalfDuplexRequest req)
void	streamOut(HalfDuplexRequest req, ResultCallback<DashScopeResult> callback)

从类继承的方法 java.lang.Object

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

字段详细资料

isFirstMessage

protected AtomicBoolean isFirstMessage

responseEmitter

protected io.reactivex.FlowableEmitter<DashScopeResult> responseEmitter

构造器详细资料

OkHttpWebSocketClient

public OkHttpWebSocketClient(okhttp3.OkHttpClient client,
                             boolean passTaskStarted)

方法详细资料

close

public boolean close(int code,
                     String reason)

指定者:

close 在接口中 FullDuplexClient

指定者:

close 在接口中 HalfDuplexClient

cancel

public void cancel()

指定者:

cancel 在接口中 FullDuplexClient

onClosed

public void onClosed(okhttp3.WebSocket webSocket,
                     int code,
                     String reason)

覆盖:

onClosed 在类中 okhttp3.WebSocketListener

onClosing

public void onClosing(okhttp3.WebSocket webSocket,
                      int code,
                      String reason)

覆盖:

onClosing 在类中 okhttp3.WebSocketListener

onFailure

public void onFailure(okhttp3.WebSocket webSocket,
                      Throwable t,
                      okhttp3.Response response)

覆盖:

onFailure 在类中 okhttp3.WebSocketListener

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
                      String text)

覆盖:

onMessage 在类中 okhttp3.WebSocketListener

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
                      okio.ByteString bytes)

覆盖:

onMessage 在类中 okhttp3.WebSocketListener

onOpen

public void onOpen(okhttp3.WebSocket webSocket,
                   okhttp3.Response response)

覆盖:

onOpen 在类中 okhttp3.WebSocketListener

sendTextWithRetry

protected void sendTextWithRetry(String apiKey,
                                 boolean isSecurityCheck,
                                 String message,
                                 String workspace,
                                 Map<String,String> customHeaders,
                                 String baseWebSocketUrl)

sendBinaryWithRetry

protected void sendBinaryWithRetry(String apiKey,
                                   boolean isSecurityCheck,
                                   okio.ByteString message,
                                   String workspace,
                                   Map<String,String> customHeaders,
                                   String baseWebSocketUrl)

send

public DashScopeResult send(HalfDuplexRequest req)

从接口复制的说明: HalfDuplexClient

Blocking send http request and get the response body.

指定者:

send 在接口中 HalfDuplexClient

参数:

req - the user input data and parameters.

返回:

The the `DashScopeResult`.

send

public void send(HalfDuplexRequest req,
                 ResultCallback<DashScopeResult> callback)

指定者:

send 在接口中 HalfDuplexClient

streamOut

public io.reactivex.Flowable<DashScopeResult> streamOut(HalfDuplexRequest req)

指定者:

streamOut 在接口中 HalfDuplexClient

streamOut

public void streamOut(HalfDuplexRequest req,
                      ResultCallback<DashScopeResult> callback)

指定者:

streamOut 在接口中 HalfDuplexClient

sendStreamRequest

protected CompletableFuture<Void> sendStreamRequest(FullDuplexRequest req)

streamIn

public DashScopeResult streamIn(FullDuplexRequest req)

指定者:

streamIn 在接口中 FullDuplexClient

streamIn

public void streamIn(FullDuplexRequest req,
                     ResultCallback<DashScopeResult> callback)
              throws NoApiKeyException,
                     ApiException

指定者:

streamIn 在接口中 FullDuplexClient

抛出:

NoApiKeyException

ApiException

duplex

public io.reactivex.Flowable<DashScopeResult> duplex(FullDuplexRequest req)
                                              throws NoApiKeyException,
                                                     ApiException

指定者:

duplex 在接口中 FullDuplexClient

抛出:

NoApiKeyException

ApiException

duplex

public void duplex(FullDuplexRequest req,
                   ResultCallback<DashScopeResult> callback)
            throws NoApiKeyException,
                   ApiException

指定者:

duplex 在接口中 FullDuplexClient

抛出:

NoApiKeyException

ApiException