com.alibaba.dashscope.protocol

Class WebsocketRpc

java.lang.Object

com.alibaba.dashscope.protocol.WebsocketRpc

public final class WebsocketRpc
extends Object

The websocket rpc, biz logic free.

Constructor Summary

Constructors

Constructor and Description
WebsocketRpc(String url, Map<String,String> headers) Construct the class.

Method Summary

Modifier and Type	Method and Description
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()

Methods inherited from class java.lang.Object

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

Constructor Detail

WebsocketRpc

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

Construct the class.

Parameters:

headers - The headers to use for connection.

url - The ws url.

Method Detail

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

call

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

Do call.

Parameters:

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.

Parameters:

request - The input request.

responseCallback - The response callback.

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