com.alibaba.dashscope.protocol

类 WebsocketRpc

java.lang.Object

com.alibaba.dashscope.protocol.WebsocketRpc

public final class WebsocketRpc
extends Object

The websocket rpc, biz logic free.

构造器概要

构造器

构造器和说明
WebsocketRpc(String url, Map<String,String> headers) Construct the class.

方法概要

限定符和类型	方法和说明
void	call(io.reactivex.Flowable<Request> requests, ResultCallback<Response> responseCallback, java.util.function.Function<String,Boolean> completeCallback) Do call.
void	call(Request request, ResultCallback<Response> responseCallback, java.util.function.Function<String,Boolean> completeCallback) Do call.
protected void	finalize()

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

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

构造器详细资料

WebsocketRpc

public WebsocketRpc(String url,
                    Map<String,String> headers)

Construct the class.

参数:

headers - The headers to use for connection.

url - The ws url.

方法详细资料

finalize

protected void finalize()
                 throws Throwable

覆盖:

finalize 在类中 Object

抛出:

Throwable

call

public void call(io.reactivex.Flowable<Request> requests,
                 ResultCallback<Response> responseCallback,
                 java.util.function.Function<String,Boolean> completeCallback)

Do call.

参数:

responseCallback - The response callback.

completeCallback - A Function to identify whether the message has completed (whether to call onComplete).

requests - The iterable input requests.

call

public void call(Request request,
                 ResultCallback<Response> responseCallback,
                 java.util.function.Function<String,Boolean> completeCallback)

Do call.

参数:

request - The input request.

responseCallback - The response callback.

completeCallback - A Function to identify whether the message has completed (whether to call onComplete).