Package akka.http.impl.engine.parsing
Interface HttpMessageParser<Output extends ParserOutput>
- All Known Implementing Classes:
HttpResponseParser
public interface HttpMessageParser<Output extends ParserOutput>
INTERNAL API
Common logic for http request and response message parsing
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic interface
static final class
static class
-
Method Summary
Modifier and TypeMethodDescription<A extends ParserOutput>
ParserOutput.StreamedEntityCreator<A,RequestEntity> chunkedEntity
(scala.Option<Content$minusType> cth) scala.Function0<scala.Option<ParserOutput.ErrorOutput>>
contentType
(scala.Option<Content$minusType> cth) <A extends ParserOutput>
ParserOutput.StreamedEntityCreator<A,UniversalEntity> defaultEntity
(scala.Option<Content$minusType> cth, long contentLength) done()
Use {@link continue} orterminate()
to suspend or terminate processing.doPull()
void
emptyEntity
(scala.Option<Content$minusType> cth) failEntityStream
(ErrorInfo info) failEntityStream
(String summary) failEntityStream
(String summary, String detail) failMessageStart
(StatusCode status) failMessageStart
(StatusCode status, ErrorInfo info) failMessageStart
(StatusCode status, String summary, String detail) failMessageStart
(String summary) failMessageStart
(String summary, String detail) scala.collection.mutable.ListBuffer<HttpHeader>
boolean
scala.runtime.Nothing$
onBadProtocol
(akka.util.ByteString input) invoked if the specified protocol is unknownparseBytes
(akka.util.ByteString input) parseChunk
(akka.util.ByteString input, int offset, boolean isLastMessage, long totalBytesRead) parseEntity
(scala.collection.immutable.List<HttpHeader> headers, HttpProtocol protocol, akka.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) parseFixedLengthBody
(long remainingBodyBytes, boolean isLastMessage, akka.util.ByteString input, int bodyStart) parseHeaderLines
(akka.util.ByteString input, int lineStart, scala.collection.mutable.ListBuffer<HttpHeader> headers, int headerCount, scala.Option<Connection> ch, scala.Option<Content$minusLength> clh, scala.Option<Content$minusType> cth, boolean isChunked, boolean e100c, boolean hh) parseHeaderLinesAux
(scala.collection.mutable.ListBuffer<HttpHeader> headers, int headerCount, scala.Option<Connection> ch, scala.Option<Content$minusLength> clh, scala.Option<Content$minusType> cth, boolean isChunked, boolean e100c, boolean hh, akka.util.ByteString input, int lineStart) parseMessage
(akka.util.ByteString input, int offset) int
parseProtocol
(akka.util.ByteString input, int cursor) parseSessionBytes
(akka.stream.TLSProtocol.SessionBytes input) void
setCompletionHandling
(scala.Function0<scala.Option<ParserOutput.ErrorOutput>> completionHandling) settings()
boolean
startNewMessage
(akka.util.ByteString input, int offset) strictEntity
(scala.Option<Content$minusType> cth, akka.util.ByteString input, int bodyStart, int contentLength) boolean
-
Method Details
-
completionHandling
scala.Function0<scala.Option<ParserOutput.ErrorOutput>> completionHandling() -
terminated
boolean terminated() -
settings
ParserSettings settings() -
headerParser
HttpHeaderParser headerParser() -
isResponseParser
boolean isResponseParser() -
onBadProtocol
scala.runtime.Nothing$ onBadProtocol(akka.util.ByteString input) invoked if the specified protocol is unknown -
parseMessage
-
parseEntity
HttpMessageParser.StateResult parseEntity(scala.collection.immutable.List<HttpHeader> headers, HttpProtocol protocol, akka.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) -
initialHeaderBuffer
scala.collection.mutable.ListBuffer<HttpHeader> initialHeaderBuffer() -
parseSessionBytes
-
parseBytes
-
doPull
Output doPull() -
shouldComplete
boolean shouldComplete() -
startNewMessage
-
parseProtocol
int parseProtocol(akka.util.ByteString input, int cursor) -
parseHeaderLines
HttpMessageParser.StateResult parseHeaderLines(akka.util.ByteString input, int lineStart, scala.collection.mutable.ListBuffer<HttpHeader> headers, int headerCount, scala.Option<Connection> ch, scala.Option<Content$minusLength> clh, scala.Option<Content$minusType> cth, boolean isChunked, boolean e100c, boolean hh) - Parameters:
ch
- connection headerclh
- content-lengthcth
- content-typeteh
- transfer-encodinge100c
- expect 100 continuehh
- host header seeninput
- (undocumented)lineStart
- (undocumented)headers
- (undocumented)headerCount
- (undocumented)isChunked
- (undocumented)- Returns:
- (undocumented)
-
parseHeaderLinesAux
HttpMessageParser.StateResult parseHeaderLinesAux(scala.collection.mutable.ListBuffer<HttpHeader> headers, int headerCount, scala.Option<Connection> ch, scala.Option<Content$minusLength> clh, scala.Option<Content$minusType> cth, boolean isChunked, boolean e100c, boolean hh, akka.util.ByteString input, int lineStart) -
parseFixedLengthBody
HttpMessageParser.StateResult parseFixedLengthBody(long remainingBodyBytes, boolean isLastMessage, akka.util.ByteString input, int bodyStart) -
parseChunk
HttpMessageParser.StateResult parseChunk(akka.util.ByteString input, int offset, boolean isLastMessage, long totalBytesRead) -
emit
-
failMessageStart
-
failMessageStart
-
failMessageStart
-
failMessageStart
-
failMessageStart
-
failEntityStream
-
failEntityStream
-
failEntityStream
-
terminate
HttpMessageParser.StateResult terminate() -
done
Use {@link continue} orterminate()
to suspend or terminate processing. Do not call this directly.- Returns:
- (undocumented)
-
contentType
-
emptyEntity
ParserOutput.StrictEntityCreator<Output,UniversalEntity> emptyEntity(scala.Option<Content$minusType> cth) -
strictEntity
ParserOutput.StrictEntityCreator<Output,UniversalEntity> strictEntity(scala.Option<Content$minusType> cth, akka.util.ByteString input, int bodyStart, int contentLength) -
defaultEntity
<A extends ParserOutput> ParserOutput.StreamedEntityCreator<A,UniversalEntity> defaultEntity(scala.Option<Content$minusType> cth, long contentLength) -
chunkedEntity
<A extends ParserOutput> ParserOutput.StreamedEntityCreator<A,RequestEntity> chunkedEntity(scala.Option<Content$minusType> cth) -
setCompletionHandling
void setCompletionHandling(scala.Function0<scala.Option<ParserOutput.ErrorOutput>> completionHandling)
-