Modifier and Type	Class and Description
public static class	ReactiveResponse.Content Collects utility methods to process response content.
public static class	ReactiveResponse.Event
public static record	ReactiveResponse.Result< the type of the response content T> A record holding the `ReactiveResponse` and the response content.

Modifier and Type	Field and Description
private String	encoding
private String	mediaType
private final ReactiveRequest	request
private final Response	response

Access	Constructor and Description
public	ReactiveResponse(ReactiveRequest request, Response response)

Modifier and Type	Method and Description
public String	Returns: the encoding specified by the `Content-Type` header getEncoding()
public HttpFields	Returns: the HTTP response headers getHeaders()
public String	Returns: the media type specified by the `Content-Type` header getMediaType()
public ReactiveRequest	Returns: the ReactiveRequest correspondent to this response getReactiveRequest()
public Response	Returns: the wrapped Jetty response getResponse()
public int	Returns: the HTTP status code getStatus()
private void	resolveContentType()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

encoding	back to summary
private String encoding

mediaType	back to summary
private String mediaType

request	back to summary
private final ReactiveRequest request

response	back to summary
private final Response response

ReactiveResponse	back to summary
public ReactiveResponse(ReactiveRequest request, Response response)

getEncoding	back to summary
public String getEncoding() Returns:String the encoding specified by the `Content-Type` header See Also `getMediaType()`

getHeaders	back to summary
public HttpFields getHeaders() Returns:HttpFields the HTTP response headers

getMediaType	back to summary
public String getMediaType() Returns:String the media type specified by the `Content-Type` header See Also `getEncoding()`

getReactiveRequest	back to summary
public ReactiveRequest getReactiveRequest() Returns:ReactiveRequest the ReactiveRequest correspondent to this response

getResponse	back to summary
public Response getResponse() Returns:Response the wrapped Jetty response

getStatus	back to summary
public int getStatus() Returns:int the HTTP status code

resolveContentType	back to summary
private void resolveContentType()

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

org.eclipse.jetty.reactive.client back to summary

public Class ReactiveResponse.Content

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.reactive.client.ReactiveResponse.Content

Collects utility methods to process response content.

Constructor Summary

Access	Constructor and Description
public	Content()

Method Summary

Modifier and Type	Method and Description
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ByteBuffer>>	Returns: a response content processing function that converts the content to a `ByteBuffer` up to 2097152 bytes. asByteBuffer()
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ByteBuffer>>	Returns: a response content processing function that converts the content to a `ByteBuffer` up to the specified maximum capacity in bytes. asByteBuffer(int maxCapacity)
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>>	Returns: a response content processing function that converts the content to a `ByteBuffer` up to 2097152 bytes, and produces a `Result` with the `ByteBuffer` content. asByteBufferResult()
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>>	Returns: a response content processing function that converts the content to a `ByteBuffer` up to the specified maximum capacity in bytes, and produces a `Result` with the `ByteBuffer` content. asByteBufferResult(int maxCapacity)
public static < the type of the content T> BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<T>>>	Returns: a response content processing function that discards the content and produces a `Result` with a `null` content of the given type. asDiscardResult()
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<String>>	Returns: a response content processing function that converts the content to a string up to 2097152 bytes. asString()
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<String>>	Returns: a response content processing function that converts the content to a string up to the specified maximum capacity in bytes. asString(int maxCapacity)
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>>	Returns: a response content processing function that converts the content to a string up to 2097152 bytes, and produces a `Result` with the string content. asStringResult()
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>>	Returns: a response content processing function that converts the content to a string up to the specified maximum capacity in bytes, and produces a `Result` with the string content. asStringResult(int maxCapacity)
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse>>	Returns: a response content processing function that discards the content discard()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

Content	back to summary
public Content()

Method Detail

asByteBuffer	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ByteBuffer>> asByteBuffer() Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ByteBuffer>> a response content processing function that converts the content to a `ByteBuffer` up to 2097152 bytes.

asByteBuffer	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ByteBuffer>> asByteBuffer(int maxCapacity) Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ByteBuffer>> a response content processing function that converts the content to a `ByteBuffer` up to the specified maximum capacity in bytes.

asByteBufferResult back to summary

asByteBufferResult	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>> asByteBufferResult() Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>> a response content processing function that converts the content to a `ByteBuffer` up to 2097152 bytes, and produces a `Result` with the `ByteBuffer` content.

public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>> asByteBufferResult()

Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>>: a response content processing function that converts the content to a ByteBuffer up to 2097152 bytes, and produces a Result with the ByteBuffer content.

asByteBufferResult back to summary

asByteBufferResult	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>> asByteBufferResult(int maxCapacity) Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>> a response content processing function that converts the content to a `ByteBuffer` up to the specified maximum capacity in bytes, and produces a `Result` with the `ByteBuffer` content.

public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>> asByteBufferResult(int maxCapacity)

Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<ByteBuffer>>>: a response content processing function that converts the content to a ByteBuffer up to the specified maximum capacity in bytes, and produces a Result with the ByteBuffer content.

asDiscardResult back to summary

asDiscardResult	back to summary
public static <T> BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<T>>> asDiscardResult() Parameters <T> the type of the content Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<T>>> a response content processing function that discards the content and produces a `Result` with a `null` content of the given type.

public static <T> BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<T>>> asDiscardResult()

Parameters

<T>: the type of the content

Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<T>>>

a response content processing function that discards the content and produces a Result with a null content of the given type.

asString	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<String>> asString() Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<String>> a response content processing function that converts the content to a string up to 2097152 bytes.

asString	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<String>> asString(int maxCapacity) Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<String>> a response content processing function that converts the content to a string up to the specified maximum capacity in bytes.

asStringResult	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>> asStringResult() Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>> a response content processing function that converts the content to a string up to 2097152 bytes, and produces a `Result` with the string content.

asStringResult back to summary

asStringResult	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>> asStringResult(int maxCapacity) Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>> a response content processing function that converts the content to a string up to the specified maximum capacity in bytes, and produces a `Result` with the string content.

public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>> asStringResult(int maxCapacity)

Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse.Result<String>>>: a response content processing function that converts the content to a string up to the specified maximum capacity in bytes, and produces a Result with the string content.

discard	back to summary
public static BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse>> discard() Returns:BiFunction<ReactiveResponse, Publisher<Content.Chunk>, Publisher<ReactiveResponse>> a response content processing function that discards the content

org.eclipse.jetty.reactive.client back to summary

public Class ReactiveResponse.Event

Class Inheritance

extends Object

java.lang.Object
org.eclipse.jetty.reactive.client.ReactiveResponse.Event

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static enum	ReactiveResponse.Event.Type

Field Summary

Modifier and Type	Field and Description
private final ByteBuffer	content
private final Throwable	failure
private final ReactiveResponse	response
private final ReactiveResponse.Event.Type	type

Constructor Summary

Access	Constructor and Description
public	Event(ReactiveResponse.Event.Type type, ReactiveResponse response)
public	Event(ReactiveResponse.Event.Type type, ReactiveResponse response, ByteBuffer content)
public	Event(ReactiveResponse.Event.Type type, ReactiveResponse response, Throwable failure)
private	Event(ReactiveResponse.Event.Type type, ReactiveResponse response, ByteBuffer content, Throwable failure)

Method Summary

Modifier and Type	Method and Description
public ByteBuffer	Returns: the event content, or null if this is not a content event getContent()
public Throwable	Returns: the event failure, or null if this is not a failure event getFailure()
public ReactiveResponse	Returns: the response that generated this event getResponse()
public ReactiveResponse.Event.Type	Returns: the event type getType()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

content	back to summary
private final ByteBuffer content

failure	back to summary
private final Throwable failure

response	back to summary
private final ReactiveResponse response

type	back to summary
private final ReactiveResponse.Event.Type type

Constructor Detail

Event	back to summary
public Event(ReactiveResponse.Event.Type type, ReactiveResponse response)

Event	back to summary
public Event(ReactiveResponse.Event.Type type, ReactiveResponse response, ByteBuffer content)

Event	back to summary
public Event(ReactiveResponse.Event.Type type, ReactiveResponse response, Throwable failure)

Event	back to summary
private Event(ReactiveResponse.Event.Type type, ReactiveResponse response, ByteBuffer content, Throwable failure)

Method Detail

getContent	back to summary
public ByteBuffer getContent() Returns:ByteBuffer the event content, or null if this is not a content event

getFailure	back to summary
public Throwable getFailure() Returns:Throwable the event failure, or null if this is not a failure event

getResponse	back to summary
public ReactiveResponse getResponse() Returns:ReactiveResponse the response that generated this event

getType	back to summary
public ReactiveResponse.Event.Type getType() Returns:ReactiveResponse.Event.Type the event type

org.eclipse.jetty.reactive.client back to summary

public final Enum ReactiveResponse.Event.Type

Class Inheritance

extends Enum<ReactiveResponse.Event.Type>

java.lang.Object
java.lang.Enum
org.eclipse.jetty.reactive.client.ReactiveResponse.Event.Type

Field Summary

Modifier and Type	Field and Description
public static final ReactiveResponse.Event.Type	BEGIN
public static final ReactiveResponse.Event.Type	COMPLETE
public static final ReactiveResponse.Event.Type	CONTENT
public static final ReactiveResponse.Event.Type	FAILURE
public static final ReactiveResponse.Event.Type	HEADERS
public static final ReactiveResponse.Event.Type	SUCCESS

Constructor Summary

Access	Constructor and Description
private	Type()

Method Summary

Modifier and Type	Method and Description
public static ReactiveResponse.Event.Type	valueOf(String name)
public static ReactiveResponse.Event.Type[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

BEGIN	back to summary
public static final ReactiveResponse.Event.Type BEGIN

COMPLETE	back to summary
public static final ReactiveResponse.Event.Type COMPLETE

CONTENT	back to summary
public static final ReactiveResponse.Event.Type CONTENT

FAILURE	back to summary
public static final ReactiveResponse.Event.Type FAILURE

HEADERS	back to summary
public static final ReactiveResponse.Event.Type HEADERS

SUCCESS	back to summary
public static final ReactiveResponse.Event.Type SUCCESS

Constructor Detail

Type	back to summary
private Type()

Method Detail

valueOf	back to summary
public static ReactiveResponse.Event.Type valueOf(String name)

values	back to summary
public static ReactiveResponse.Event.Type[] values()

org.eclipse.jetty.reactive.client back to summary

public final Record ReactiveResponse.Result<T>

Class Inheritance

extends Record

java.lang.Object
java.lang.Record
org.eclipse.jetty.reactive.client.ReactiveResponse.Result

Record Components

response:ReactiveResponse: the response
content:T: the response content

Type Parameters

<T>: the type of the response content

A record holding the ReactiveResponse and the response content.

Field Summary

Modifier and Type	Field and Description
private final T	content Record Component accessed by content(). the response content
private final ReactiveResponse	response Record Component accessed by response(). the response

Constructor Summary

Access	Constructor and Description
public	Result(ReactiveResponse response, T content)

Method Summary

Modifier and Type	Method and Description
public T	content() Record Component getter of content. Record Component the response content
public final boolean	equals(Object the reference object with which to compare. o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
public ReactiveResponse	response() Record Component getter of response. Record Component the response
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.

Field Detail

content

back to summary

private final T content

Record Component accessed by content().

the response content

response

back to summary

private final ReactiveResponse response

Record Component accessed by response().

the response

Constructor Detail

Result	back to summary
public Result(ReactiveResponse response, T content)

Method Detail

content

back to summary

public T content()

Record Component getter of content.

Record Component: the response content

equals back to summary

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

Indicates whether some other object is "equal to" this one. In addition to the general contract of Object.equals, record classes must further obey the invariant that when a record instance is "copied" by passing the result of the record component accessor methods to the canonical constructor, as follows:

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

Parameters

o:Object: the reference object with which to compare.

Returns:boolean

true if this record is equal to the argument; false otherwise.

hashCode back to summary

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

Returns a hash code value for the record. Obeys the general contract of Object.hashCode. For records, hashing behavior is constrained by the refined contract of Record.equals, so that any two records created from the same components must have the same hash code.

Returns:int: a hash code value for this record.

response

back to summary

public ReactiveResponse response()

Record Component getter of response.

Record Component: the response

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

Returns a string representation of the record. In accordance with the general contract of Object#toString(), the toString method returns a string that "textually represents" this record. The result should be a concise but informative representation that is easy for a person to read.

In addition to this general contract, record classes must further participate in the invariant that any two records which are equal must produce equal strings. This invariant is necessarily relaxed in the rare case where corresponding equal component values might fail to produce equal strings for themselves.

Returns:String: a string representation of the object.