public static class WebRxStreamableHttpTransport.Builder
extends java.lang.Object
WebRxStreamableHttpTransport
.限定符和类型 | 方法和说明 |
---|---|
WebRxStreamableHttpTransport |
build()
Construct a fresh instance of
WebRxStreamableHttpTransport using
the current builder configuration. |
WebRxStreamableHttpTransport.Builder |
endpoint(java.lang.String endpoint)
Configure the endpoint to make HTTP requests against.
|
WebRxStreamableHttpTransport.Builder |
objectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
Configure the
ObjectMapper to use. |
WebRxStreamableHttpTransport.Builder |
openConnectionOnStartup(boolean openConnectionOnStartup)
Configure whether the client should open an SSE connection upon startup.
|
WebRxStreamableHttpTransport.Builder |
resumableStreams(boolean resumableStreams)
Configure whether to use the stream resumability feature by keeping track of
SSE event ids.
|
WebRxStreamableHttpTransport.Builder |
webClientBuilder(org.noear.solon.net.http.HttpUtilsBuilder webClientBuilder)
Configure the
HttpUtilsBuilder to construct the HttpUtils . |
public WebRxStreamableHttpTransport.Builder objectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
ObjectMapper
to use.objectMapper
- instance to usepublic WebRxStreamableHttpTransport.Builder webClientBuilder(org.noear.solon.net.http.HttpUtilsBuilder webClientBuilder)
HttpUtilsBuilder
to construct the HttpUtils
.webClientBuilder
- instance to usepublic WebRxStreamableHttpTransport.Builder endpoint(java.lang.String endpoint)
endpoint
- endpoint to usepublic WebRxStreamableHttpTransport.Builder resumableStreams(boolean resumableStreams)
resumableStreams
- if true
event ids will be tracked and upon
disconnection, the last seen id will be used upon reconnection as a header to
resume consuming messages.public WebRxStreamableHttpTransport.Builder openConnectionOnStartup(boolean openConnectionOnStartup)
false
.openConnectionOnStartup
- if true
the WebRxStreamableHttpTransport.connect(Function)
method call will try to open an SSE connection before sending any JSON-RPC
requestpublic WebRxStreamableHttpTransport build()
WebRxStreamableHttpTransport
using
the current builder configuration.WebRxStreamableHttpTransport