Package io.servicetalk.http.api

Class DefaultStreamingHttpRequestResponseFactory

java.lang.Object

io.servicetalk.http.api.DefaultStreamingHttpRequestResponseFactory

All Implemented Interfaces:

StreamingHttpRequestFactory, StreamingHttpRequestResponseFactory, StreamingHttpResponseFactory

public final class DefaultStreamingHttpRequestResponseFactory
extends Object
implements StreamingHttpRequestResponseFactory

A default implementation for StreamingHttpRequestFactory and StreamingHttpResponseFactory.

Constructor Summary

Constructors

Constructor	Description
DefaultStreamingHttpRequestResponseFactory(BufferAllocator allocator, HttpHeadersFactory headersFactory, HttpProtocolVersion protocolVersion)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
StreamingHttpRequest	newRequest(HttpRequestMethod method, String requestTarget)	Create a new HttpRequestFactory.
StreamingHttpResponse	newResponse(HttpResponseStatus status)	Create a new StreamingHttpResponse object.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.servicetalk.http.api.StreamingHttpRequestFactory

connect, delete, get, head, options, patch, post, put, trace

Methods inherited from interface io.servicetalk.http.api.StreamingHttpResponseFactory

accepted, alreadyReported, badGateway, badRequest, conflict, continueResponse, created, earlyHints, expectationFailed, failedDependency, forbidden, found, gatewayTimeout, gone, httpVersionNotSupported, imUsed, insufficientStorage, internalServerError, lengthRequired, locked, loopDetected, methodNotAllowed, misdirectedRequest, movedPermanently, multipleChoices, multiStatus, networkAuthenticationRequired, noContent, nonAuthoritativeInformation, notAcceptable, notExtended, notFound, notImplemented, notModified, ok, partialContent, payloadTooLarge, paymentRequired, permanentRedirect, preconditionFailed, preconditionRequired, processing, proxyAuthenticationRequired, rangeNotSatisfiable, requestHeaderFieldsTooLarge, requestTimeout, resetContent, seeOther, serviceUnavailable, switchingProtocols, temporaryRedirect, tooEarly, tooManyRequests, unauthorized, unavailableForLegalReasons, unprocessableEntity, unsupportedMediaType, upgradeRequired, uriTooLong, useProxy, variantAlsoNegotiates

Constructor Details

DefaultStreamingHttpRequestResponseFactory

public DefaultStreamingHttpRequestResponseFactory(BufferAllocator allocator,
 HttpHeadersFactory headersFactory,
 HttpProtocolVersion protocolVersion)

Create a new instance.

Parameters:

allocator - The BufferAllocator to use for serialization.

headersFactory - The HttpHeadersFactory to use for request/response creation.

protocolVersion - The HttpProtocolVersion to use for new requests/responses.

Method Details

newRequest

public StreamingHttpRequest newRequest(HttpRequestMethod method,
 String requestTarget)

Description copied from interface: StreamingHttpRequestFactory

Create a new HttpRequestFactory.

Specified by:

newRequest in interface StreamingHttpRequestFactory

Parameters:

method - The HttpRequestMethod.

requestTarget - The request target.

Returns:

a new HttpRequestFactory.

newResponse

public StreamingHttpResponse newResponse(HttpResponseStatus status)

Description copied from interface: StreamingHttpResponseFactory

Create a new StreamingHttpResponse object.

Specified by:

newResponse in interface StreamingHttpResponseFactory

Parameters:

status - The HttpResponseStatus.

Returns:

a new StreamingHttpResponse object.