io.vertx.rxjava3.httpproxy

Class ProxyRequest

java.lang.Object

io.vertx.rxjava3.httpproxy.ProxyRequest

public class ProxyRequest
extends Object

Handles the interoperability of the request between the user agent and the origin.

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<ProxyRequest>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
ProxyRequest(Object delegate)
ProxyRequest(ProxyRequest delegate)

Method Summary

Modifier and Type	Method and Description
String	absoluteURI()
ProxyRequest	bodyFilter(java.util.function.Function<ReadStream<Buffer>,Flowable<Buffer>> filter) Set a body filter.
boolean	equals(Object o)
Body	getBody()
ProxyRequest	getDelegate()
HttpMethod	getMethod()
String	getURI()
int	hashCode()
MultiMap	headers()
static ProxyRequest	newInstance(ProxyRequest arg)
HttpServerRequest	outboundRequest()
Completable	proxy(HttpClientRequest inboundRequest) Proxy this outbound request and response to the origin server using the specified inbound request.
ProxyRequest	release() Release the proxy request.
ProxyResponse	response() Create and return the proxy response.
static ProxyRequest	reverseProxy(HttpServerRequest outboundRequest) Create a new ProxyRequest instance, the outbound request will be paused.
Completable	rxProxy(HttpClientRequest inboundRequest) Proxy this outbound request and response to the origin server using the specified inbound request.
Single<ProxyResponse>	rxSend(HttpClientRequest inboundRequest) Send this request to the origin server using the specified inbound request.
Single<ProxyResponse>	send(HttpClientRequest inboundRequest) Send this request to the origin server using the specified inbound request.
ProxyRequest	setBody(Body body) Set the request body to be sent to the origin server.
ProxyRequest	setMethod(HttpMethod method) Set the HTTP method to be sent to the origin server.
ProxyRequest	setURI(String uri) Set the request URI to be sent to the origin server.
String	toString()
HttpVersion	version()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final io.vertx.lang.rx.TypeArg<ProxyRequest> __TYPE_ARG

Constructor Detail

ProxyRequest

public ProxyRequest(ProxyRequest delegate)

ProxyRequest

public ProxyRequest(Object delegate)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getDelegate

public ProxyRequest getDelegate()

reverseProxy

public static ProxyRequest reverseProxy(HttpServerRequest outboundRequest)

Create a new ProxyRequest instance, the outbound request will be paused.

Parameters:

outboundRequest - the HttpServerRequest of the user agent

Returns:

a reference to this, so the API can be used fluently

version

public HttpVersion version()

Returns:

the HTTP version of the outbound request

absoluteURI

public String absoluteURI()

Returns:

the absolute URI of the outbound request

getMethod

public HttpMethod getMethod()

Returns:

the HTTP method to be sent to the origin server.

setMethod

public ProxyRequest setMethod(HttpMethod method)

Set the HTTP method to be sent to the origin server.

The initial HTTP method value is the outbound request HTTP method.

Parameters:

method - the new HTTP method

Returns:

a reference to this, so the API can be used fluently

getURI

public String getURI()

Returns:

the request URI to be sent to the origin server.

setURI

public ProxyRequest setURI(String uri)

Set the request URI to be sent to the origin server.

The initial request URI value is the outbound request URI.

Parameters:

uri - the new URI

Returns:

a reference to this, so the API can be used fluently

getBody

public Body getBody()

Returns:

the request body to be sent to the origin server.

setBody

public ProxyRequest setBody(Body body)

Set the request body to be sent to the origin server.

The initial request body value is the outbound request body.

Parameters:

body - the new body

Returns:

a reference to this, so the API can be used fluently

headers

public MultiMap headers()

Returns:

the headers that will be sent to the origin server, the returned headers can be modified. The headers map is populated with the outbound request headers

bodyFilter

public ProxyRequest bodyFilter(java.util.function.Function<ReadStream<Buffer>,Flowable<Buffer>> filter)

Set a body filter.

The body filter can rewrite the request body sent to the origin server.

Parameters:

filter - the filter

Returns:

a reference to this, so the API can be used fluently

proxy

public Completable proxy(HttpClientRequest inboundRequest)

Proxy this outbound request and response to the origin server using the specified inbound request.

Parameters:

inboundRequest - the request connected to the origin server

Returns:

rxProxy

public Completable rxProxy(HttpClientRequest inboundRequest)

Proxy this outbound request and response to the origin server using the specified inbound request.

Parameters:

inboundRequest - the request connected to the origin server

Returns:

send

public Single<ProxyResponse> send(HttpClientRequest inboundRequest)

Send this request to the origin server using the specified inbound request.

The completionHandler will be called with the proxy response sent by the origin.

Parameters:

inboundRequest - the request connected to the origin server

Returns:

rxSend

public Single<ProxyResponse> rxSend(HttpClientRequest inboundRequest)

Send this request to the origin server using the specified inbound request.

The completionHandler will be called with the proxy response sent by the origin.

Parameters:

inboundRequest - the request connected to the origin server

Returns:

release

public ProxyRequest release()

Release the proxy request.

The HTTP server request is resumed, no HTTP server response is sent.

Returns:

a reference to this, so the API can be used fluently

outboundRequest

public HttpServerRequest outboundRequest()

Returns:

the outbound HTTP server request

response

public ProxyResponse response()

Create and return the proxy response.

Returns:

the proxy response

newInstance

public static ProxyRequest newInstance(ProxyRequest arg)