Package dev.langchain4j.model.qianfan.client

Class RequestExecutor<Request,Response,ResponseContent>

java.lang.Object

dev.langchain4j.model.qianfan.client.RequestExecutor<Request,Response,ResponseContent>

All Implemented Interfaces:

SyncOrAsync<ResponseContent>, SyncOrAsyncOrStreaming<ResponseContent>

public class RequestExecutor<Request,Response,ResponseContent>
extends Object
implements SyncOrAsyncOrStreaming<ResponseContent>

Constructor Summary

Constructors

Constructor	Description
RequestExecutor(retrofit2.Call<Response> call, Function<Response,ResponseContent> responseContentExtractor)
RequestExecutor(retrofit2.Call<Response> call, Function<Response,ResponseContent> responseContentExtractor, Supplier<Request> requestWithStreamSupplier, Class<Response> responseClass, Function<Response,ResponseContent> streamEventContentExtractor)
RequestExecutor(retrofit2.Call<Response> call, Function<Response,ResponseContent> responseContentExtractor, okhttp3.OkHttpClient okHttpClient, String endpointUrl, Supplier<Request> requestWithStreamSupplier, Class<Response> responseClass, Function<Response,ResponseContent> streamEventContentExtractor, boolean logStreamingResponses)

Method Summary

Modifier and Type	Method	Description
ResponseContent	execute()
StreamingResponseHandling	onPartialResponse(Consumer<ResponseContent> partialResponseHandler)
AsyncResponseHandling	onResponse(Consumer<ResponseContent> responseHandler)

Methods inherited from class java.lang.Object

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

Constructor Details

RequestExecutor

public RequestExecutor(retrofit2.Call<Response> call,
 Function<Response,ResponseContent> responseContentExtractor,
 okhttp3.OkHttpClient okHttpClient,
 String endpointUrl,
 Supplier<Request> requestWithStreamSupplier,
 Class<Response> responseClass,
 Function<Response,ResponseContent> streamEventContentExtractor,
 boolean logStreamingResponses)

RequestExecutor

public RequestExecutor(retrofit2.Call<Response> call,
 Function<Response,ResponseContent> responseContentExtractor,
 Supplier<Request> requestWithStreamSupplier,
 Class<Response> responseClass,
 Function<Response,ResponseContent> streamEventContentExtractor)

RequestExecutor

public RequestExecutor(retrofit2.Call<Response> call,
 Function<Response,ResponseContent> responseContentExtractor)

Method Details

execute

public ResponseContent execute()

Specified by:

execute in interface SyncOrAsync<Request>

onResponse

public AsyncResponseHandling onResponse(Consumer<ResponseContent> responseHandler)

Specified by:

onResponse in interface SyncOrAsync<Request>

onPartialResponse

public StreamingResponseHandling onPartialResponse(Consumer<ResponseContent> partialResponseHandler)

Specified by:

onPartialResponse in interface SyncOrAsyncOrStreaming<Request>