Package org.apache.pekko.http.impl.engine.parsing

Class HttpResponseParser

java.lang.Object

org.apache.pekko.http.impl.engine.parsing.HttpResponseParser

All Implemented Interfaces:

HttpMessageParser<ParserOutput.ResponseOutput>

public class HttpResponseParser
extends Object
implements HttpMessageParser<ParserOutput.ResponseOutput>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HttpResponseParser.OneHundredContinueError$
static final class	HttpResponseParser.ResponseContext	param: requestMethod the request's HTTP method param: oneHundredContinueTrigger if the request contains an Expect: 100-continue header this option contains a promise whose completion either triggers the sending of the (suspended) request entity or the closing of the connection (for error completion)
static class	HttpResponseParser.ResponseContext$

Nested classes/interfaces inherited from interface org.apache.pekko.http.impl.engine.parsing.HttpMessageParser

HttpMessageParser.StateResult, HttpMessageParser.Trampoline, HttpMessageParser.Trampoline$

Constructor Summary

Constructors

Constructor	Description
HttpResponseParser(ParserSettings settings, HttpHeaderParser headerParser)

Method Summary

Modifier and Type	Method	Description
protected scala.Function0<scala.Option<ParserOutput.ErrorOutput>>	completionHandling()
final HttpResponseParser	createShallowCopy()
final void	emit(ParserOutput.ResponseOutput output)
boolean	handleInformationalResponses()
protected HttpHeaderParser	headerParser()
final boolean	isResponseParser()
final scala.runtime.Nothing$	onBadProtocol(org.apache.pekko.util.ByteString input)	invoked if the specified protocol is unknown
final ParserOutput.ResponseOutput	onPull()
final boolean	onUpstreamFinish()
protected final HttpMessageParser.StateResult	parseEntity(scala.collection.immutable.List<HttpHeader> headers, HttpProtocol protocol, org.apache.pekko.util.ByteString input, int bodyStart, scala.Option<Content$minusLength> clh, scala.Option<Content$minusType> cth, boolean isChunked, boolean expect100continue, boolean hostHeaderPresent, boolean closeAfterResponseCompletion, SSLSession sslSession)
protected HttpMessageParser.StateResult	parseMessage(org.apache.pekko.util.ByteString input, int offset)
final void	setContextForNextResponse(HttpResponseParser.ResponseContext responseContext)
protected ParserSettings	settings()
protected boolean	terminated()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.http.impl.engine.parsing.HttpMessageParser

chunkedEntity, contentType, defaultEntity, done, doPull, emptyEntity, failEntityStream, failEntityStream, failEntityStream, failMessageStart, failMessageStart, failMessageStart, failMessageStart, failMessageStart, initialHeaderBuffer, parseBytes, parseChunk, parseFixedLengthBody, parseHeaderLines, parseHeaderLinesAux, parseProtocol, parseSessionBytes, setCompletionHandling, shouldComplete, startNewMessage, strictEntity, terminate

Constructor Details

HttpResponseParser

public HttpResponseParser(ParserSettings settings,
 HttpHeaderParser headerParser)

Method Details

completionHandling

protected scala.Function0<scala.Option<ParserOutput.ErrorOutput>> completionHandling()

Specified by:

completionHandling in interface HttpMessageParser<ParserOutput.ResponseOutput>

terminated

protected boolean terminated()

Specified by:

terminated in interface HttpMessageParser<ParserOutput.ResponseOutput>

settings

protected ParserSettings settings()

Specified by:

settings in interface HttpMessageParser<ParserOutput.ResponseOutput>

headerParser

protected HttpHeaderParser headerParser()

Specified by:

headerParser in interface HttpMessageParser<ParserOutput.ResponseOutput>

isResponseParser

public final boolean isResponseParser()

Specified by:

isResponseParser in interface HttpMessageParser<ParserOutput.ResponseOutput>

createShallowCopy

public final HttpResponseParser createShallowCopy()

setContextForNextResponse

public final void setContextForNextResponse(HttpResponseParser.ResponseContext responseContext)

onPull

public final ParserOutput.ResponseOutput onPull()

onUpstreamFinish

public final boolean onUpstreamFinish()

emit

public final void emit(ParserOutput.ResponseOutput output)

Specified by:

emit in interface HttpMessageParser<ParserOutput.ResponseOutput>

parseMessage

protected HttpMessageParser.StateResult parseMessage(org.apache.pekko.util.ByteString input,
 int offset)

Specified by:

parseMessage in interface HttpMessageParser<ParserOutput.ResponseOutput>

onBadProtocol

public final scala.runtime.Nothing$ onBadProtocol(org.apache.pekko.util.ByteString input)

Description copied from interface: HttpMessageParser

invoked if the specified protocol is unknown

Specified by:

onBadProtocol in interface HttpMessageParser<ParserOutput.ResponseOutput>

handleInformationalResponses

public boolean handleInformationalResponses()

parseEntity

protected final HttpMessageParser.StateResult parseEntity(scala.collection.immutable.List<HttpHeader> headers,
 HttpProtocol protocol,
 org.apache.pekko.util.ByteString input,
 int bodyStart,
 scala.Option<Content$minusLength> clh,
 scala.Option<Content$minusType> cth,
 boolean isChunked,
 boolean expect100continue,
 boolean hostHeaderPresent,
 boolean closeAfterResponseCompletion,
 SSLSession sslSession)

Specified by:

parseEntity in interface HttpMessageParser<ParserOutput.ResponseOutput>