Package io.getstream.services.framework

Class StreamRequest<T>

java.lang.Object

io.getstream.services.framework.StreamRequest<T>

public class StreamRequest<T>
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamRequest(StreamHTTPClient client, String method, String path, Object jRequest, Map<String,String> pathParams, com.fasterxml.jackson.core.type.TypeReference<T> typeReference)	Preferred constructor: derives the transport, base URL, logger and log-bodies flag from client, so the request emits the SDK's structured log events.
StreamRequest(okhttp3.OkHttpClient client, com.fasterxml.jackson.databind.ObjectMapper mapper, String baseURL, String method, String path, Object jRequest, Map<String,String> pathParams, com.fasterxml.jackson.core.type.TypeReference<T> typeReference)

Method Summary

Modifier and Type	Method	Description
okhttp3.HttpUrl	buildUrl(String baseUrl, String path, Map<String,String> pathParams, Object queryParams)
StreamRequest<T>	callTimeout(Duration d)	Override the per-call timeout for this single request.
StreamResponse<T>	execute()	Runs the request, retrying per retryConfig (opt-in, disabled by default — see RetryConfig).

Methods inherited from class java.lang.Object

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

Constructor Details

StreamRequest

public StreamRequest(StreamHTTPClient client,
 String method,
 String path,
 Object jRequest,
 Map<String,String> pathParams,
 com.fasterxml.jackson.core.type.TypeReference<T> typeReference)
              throws StreamException

Preferred constructor: derives the transport, base URL, logger and log-bodies flag from client, so the request emits the SDK's structured log events.

Throws:

StreamException

StreamRequest

public StreamRequest(okhttp3.OkHttpClient client,
 com.fasterxml.jackson.databind.ObjectMapper mapper,
 String baseURL,
 String method,
 String path,
 Object jRequest,
 Map<String,String> pathParams,
 com.fasterxml.jackson.core.type.TypeReference<T> typeReference)
              throws StreamException

Throws:

StreamException

Method Details

buildUrl

public okhttp3.HttpUrl buildUrl(String baseUrl,
 String path,
 Map<String,String> pathParams,
 Object queryParams)
                         throws com.fasterxml.jackson.core.JsonProcessingException,
NullPointerException,
IllegalAccessException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

NullPointerException

IllegalAccessException

callTimeout

public StreamRequest<T> callTimeout(@NotNull
 Duration d)

Override the per-call timeout for this single request. The override takes precedence over the client-wide RequestTimeout configured via StreamClientOptions.setRequestTimeout(java.time.Duration). Returns this for chaining.

Per CHA-2956.

execute

public StreamResponse<T> execute()
                          throws StreamException

Runs the request, retrying per retryConfig (opt-in, disabled by default — see RetryConfig). Only GET/HEAD requests failing with HTTP 429 (non-unrecoverable) or a transport error are retried; the last attempt's error is always what surfaces. Per CHA-2959.

Throws:

StreamException