@Prototype @Requires(classes=com.netflix.client.config.IClientConfig.class) @Primary @Replaces(value=DefaultHttpClient.class) public class RibbonRxHttpClient extends DefaultHttpClient
DefaultHttpClient adapted to Ribbon.DefaultHttpClient.HttpClientInitializer, DefaultHttpClient.NettyRequestWriterbootstrap, byteBufferFactory, group, HANDLER_AGGREGATOR, HANDLER_CHUNK, HANDLER_DECODER, HANDLER_STREAM, mediaTypeCodecRegistry| Constructor and Description |
|---|
RibbonRxHttpClient(LoadBalancer loadBalancer,
HttpClientConfiguration configuration,
String contextPath,
ThreadFactory threadFactory,
NettyClientSslBuilder nettyClientSslBuilder,
MediaTypeCodecRegistry codecRegistry,
RibbonExecutionListenerAdapter[] executionListeners,
AnnotationMetadataResolver annotationMetadataResolver,
HttpClientFilter... filters)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
protected <O> com.netflix.loadbalancer.reactive.LoadBalancerCommand<O> |
buildLoadBalancerCommand()
Build the command using the load balancer builder.
|
<I> io.reactivex.Flowable<ByteBuffer<?>> |
dataStream(HttpRequest<I> request)
Request a stream of data where each emitted item is a
ByteBuffer instance. |
<I,O> io.reactivex.Flowable<HttpResponse<O>> |
exchange(HttpRequest<I> request,
Argument<O> bodyType)
Perform an HTTP request for the given request object emitting the full HTTP response from returned
Publisher and converting the response body to the specified type. |
<I> io.reactivex.Flowable<HttpResponse<ByteBuffer<?>>> |
exchangeStream(HttpRequest<I> request)
Requests a stream data where each emitted item is a
ByteBuffer wrapped in the HttpResponse object
(which remains the same for each emitted item). |
Optional<RibbonLoadBalancer> |
getLoadBalancer() |
<I,O> io.reactivex.Flowable<O> |
jsonStream(HttpRequest<I> request,
Argument<O> type)
Perform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
|
applyFilterToResponsePublisher, buildDataStreamPublisher, buildExchangePublisher, buildExchangeStreamPublisher, buildJsonStreamPublisher, buildNettyRequest, buildSslContext, buildStreamExchange, closeChannelAsync, configureProxy, createEventLoopGroup, doConnect, doConnect, doConnect, eventStream, eventStream, getLoadBalancerDiscriminator, getMediaTypeCodecRegistry, isRunning, jsonStream, jsonStream, resolveFilters, resolveRequestURI, resolveRequestURI, setClientIdentifiers, setClientIdentifiers, setMediaTypeCodecRegistry, start, stop, toBlockingclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreateexchange, exchange, exchange, exchange, retrieve, retrieve, retrieve, retrieverefresheventStream, eventStream, eventStream@Inject public RibbonRxHttpClient(@Parameter LoadBalancer loadBalancer, @Parameter HttpClientConfiguration configuration, @Parameter @Nullable String contextPath, @Named(value="netty") @Nullable ThreadFactory threadFactory, NettyClientSslBuilder nettyClientSslBuilder, MediaTypeCodecRegistry codecRegistry, RibbonExecutionListenerAdapter[] executionListeners, @Nullable AnnotationMetadataResolver annotationMetadataResolver, HttpClientFilter... filters)
loadBalancer - loadBalancerconfiguration - configurationcontextPath - contextPaththreadFactory - threadFactorynettyClientSslBuilder - nettyClientSslBuildercodecRegistry - codecRegistryexecutionListeners - executionListenersannotationMetadataResolver - annotationMetadataResolverfilters - filterspublic Optional<RibbonLoadBalancer> getLoadBalancer()
RibbonLoadBalancer if one is configured for this clientpublic <I,O> io.reactivex.Flowable<HttpResponse<O>> exchange(HttpRequest<I> request, Argument<O> bodyType)
HttpClientPerform an HTTP request for the given request object emitting the full HTTP response from returned
Publisher and converting the response body to the specified type.
This method will send a Content-Length header and except a content length header the response and is
designed for simple non-streaming exchanges of data
By default the exchange Content-Type is application/json, unless otherwise specified in the passed
HttpRequest
exchange in interface HttpClientexchange in interface RxHttpClientexchange in class DefaultHttpClientI - The request body typeO - The response body typerequest - The HttpRequest to executebodyType - The body typePublisher that emits the full HttpResponse objectpublic <I> io.reactivex.Flowable<HttpResponse<ByteBuffer<?>>> exchangeStream(HttpRequest<I> request)
StreamingHttpClientByteBuffer wrapped in the HttpResponse object
(which remains the same for each emitted item).exchangeStream in interface RxStreamingHttpClientexchangeStream in interface StreamingHttpClientexchangeStream in class DefaultHttpClientI - The request body typerequest - The HttpRequestPublisher that emits a stream of ByteBuffer instances wrapped by a HttpResponsepublic <I> io.reactivex.Flowable<ByteBuffer<?>> dataStream(HttpRequest<I> request)
StreamingHttpClientByteBuffer instance.dataStream in interface RxStreamingHttpClientdataStream in interface StreamingHttpClientdataStream in class DefaultHttpClientI - The request body typerequest - The requestPublisher that emits a stream of ByteBuffer instancespublic <I,O> io.reactivex.Flowable<O> jsonStream(HttpRequest<I> request, Argument<O> type)
StreamingHttpClientPerform an HTTP request and receive data as a stream of JSON objects as they become available without blocking.
The downstream Subscriber can regulate demand via the subscription. Incoming data
is buffered.
jsonStream in interface RxStreamingHttpClientjsonStream in interface StreamingHttpClientjsonStream in class DefaultHttpClientI - The request body typeO - The response typerequest - The HttpRequest to executetype - The type of object to convert the JSON intoPublisher that emits the full HttpResponse objectprotected <O> com.netflix.loadbalancer.reactive.LoadBalancerCommand<O> buildLoadBalancerCommand()
O - entity type of the command