Modifier and Type	Class and Description
pack-priv static interface	ResponseContent.BodyParser
pack-priv class	ResponseContent.ChunkedBodyParser
pack-priv static enum	ResponseContent.ChunkState
pack-priv class	ResponseContent.FixedLengthBodyParser
pack-priv class	ResponseContent.UnknownLengthBodyParser

Modifier and Type	Field and Description
private boolean	chunkedContent
private boolean	chunkedContentInitialized
pack-priv final long	contentLength
pack-priv static final int	CR
private final String	dbgTag
pack-priv final HttpHeaders	headers
pack-priv static final int	LF
pack-priv static final int	MAX_CHUNK_HEADER_SIZE
private final Runnable	onFinished
pack-priv final HttpResponse.BodySubscriber<?>	pusher

Access	Constructor and Description
pack-priv	ResponseContent(HttpConnection connection, long contentLength, HttpHeaders h, HttpResponse.BodySubscriber<?> userSubscriber, Runnable onFinished)

Modifier and Type	Method and Description
pack-priv boolean	contentChunked()
pack-priv ResponseContent.BodyParser	getBodyParser(Consumer<Throwable> onComplete)

chunkedContent	back to summary
private boolean chunkedContent

chunkedContentInitialized	back to summary
private boolean chunkedContentInitialized

contentLength	back to summary
pack-priv final long contentLength

CR	back to summary
pack-priv static final int CR

dbgTag	back to summary
private final String dbgTag

headers	back to summary
pack-priv final HttpHeaders headers

LF	back to summary
pack-priv static final int LF

MAX_CHUNK_HEADER_SIZE	back to summary
pack-priv static final int MAX_CHUNK_HEADER_SIZE

onFinished	back to summary
private final Runnable onFinished

pusher	back to summary
pack-priv final HttpResponse.BodySubscriber<?> pusher

ResponseContent	back to summary
pack-priv ResponseContent(HttpConnection connection, long contentLength, HttpHeaders h, HttpResponse.BodySubscriber<?> userSubscriber, Runnable onFinished)

contentChunked	back to summary
pack-priv boolean contentChunked() throws IOException

getBodyParser	back to summary
pack-priv ResponseContent.BodyParser getBodyParser(Consumer<Throwable> onComplete) throws IOException

Modifier and Type	Method and Description
public String	currentStateMessage()
public void	onError(Throwable t)
public void	onSubscribe(AbstractSubscription sub)

currentStateMessage	back to summary
public String currentStateMessage()

onError	back to summary
public void onError(Throwable t)

onSubscribe	back to summary
public void onSubscribe(AbstractSubscription sub)

pack-priv Class ResponseContent.ChunkedBodyParser

Class Inheritance

java.lang.Object
jdk.internal.net.http.ResponseContent.ChunkedBodyParser

All Implemented Interfaces

jdk.internal.net.http.ResponseContent.BodyParser, java.util.function.Consumer

Field Summary

Modifier and Type	Field and Description
pack-priv volatile int	bytesremaining
pack-priv volatile int	bytesToConsume
pack-priv volatile int	chunkext
pack-priv volatile int	chunklen
pack-priv volatile Throwable	closedExceptionally
pack-priv volatile boolean	cr
pack-priv final String	dbgTag
pack-priv final Logger	debug
pack-priv volatile int	digits
pack-priv final Consumer<Throwable>	onComplete
pack-priv volatile int	partialChunklen
pack-priv final ByteBuffer	READMORE
pack-priv volatile ResponseContent.ChunkState	state
pack-priv volatile AbstractSubscription	sub

Constructor Summary

Access	Constructor and Description
pack-priv	ChunkedBodyParser(Consumer<Throwable> onComplete)

Method Summary

Modifier and Type	Method and Description
public void	accept(ByteBuffer b) Implements java.util.function.Consumer.accept. Performs this operation on the given argument.
public String	currentStateMessage() Implements jdk.internal.net.http.ResponseContent.BodyParser.currentStateMessage.
pack-priv String	dbgString()
private void	debugBuffer(ByteBuffer b)
public void	onError(Throwable t) Implements jdk.internal.net.http.ResponseContent.BodyParser.onError.
public void	onSubscribe(AbstractSubscription sub) Implements jdk.internal.net.http.ResponseContent.BodyParser.onSubscribe.
private int	toDigit(int b)
private int	tryConsumeBytes(ByteBuffer chunkbuf)
private boolean	tryPushOneHunk(ByteBuffer b, List<ByteBuffer> out)
private int	tryReadChunkLen(ByteBuffer chunkbuf)
pack-priv ByteBuffer	tryReadOneHunk(ByteBuffer chunk) Returns a ByteBuffer containing chunk of data or a "hunk" of data (a chunk of a chunk if the chunk size is larger than our ByteBuffers).

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

Field Detail

bytesremaining	back to summary
pack-priv volatile int bytesremaining

bytesToConsume	back to summary
pack-priv volatile int bytesToConsume

chunkext	back to summary
pack-priv volatile int chunkext

chunklen	back to summary
pack-priv volatile int chunklen

closedExceptionally	back to summary
pack-priv volatile Throwable closedExceptionally

cr	back to summary
pack-priv volatile boolean cr

dbgTag	back to summary
pack-priv final String dbgTag

debug	back to summary
pack-priv final Logger debug

digits	back to summary
pack-priv volatile int digits

onComplete	back to summary
pack-priv final Consumer<Throwable> onComplete

partialChunklen	back to summary
pack-priv volatile int partialChunklen

READMORE	back to summary
pack-priv final ByteBuffer READMORE

state	back to summary
pack-priv volatile ResponseContent.ChunkState state

sub	back to summary
pack-priv volatile AbstractSubscription sub

Constructor Detail

ChunkedBodyParser	back to summary
pack-priv ChunkedBodyParser(Consumer<Throwable> onComplete)

Method Detail

accept	back to summary
public void accept(ByteBuffer b) Implements java.util.function.Consumer.accept. Doc from java.util.function.Consumer.accept. Performs this operation on the given argument. Annotations @Override

back to summary

public void accept(ByteBuffer b)

Implements java.util.function.Consumer.accept.

Doc from java.util.function.Consumer.accept.

Performs this operation on the given argument.

Annotations

@Override

currentStateMessage	back to summary
public String currentStateMessage() Implements jdk.internal.net.http.ResponseContent.BodyParser.currentStateMessage. Annotations @Override

currentStateMessage

back to summary

public String currentStateMessage()

Implements jdk.internal.net.http.ResponseContent.BodyParser.currentStateMessage.

Annotations

@Override

dbgString	back to summary
pack-priv String dbgString()

debugBuffer	back to summary
private void debugBuffer(ByteBuffer b)

onError	back to summary
public void onError(Throwable t) Implements jdk.internal.net.http.ResponseContent.BodyParser.onError. Annotations @Override

onError

back to summary

public void onError(Throwable t)

Implements jdk.internal.net.http.ResponseContent.BodyParser.onError.

Annotations

@Override

onSubscribe	back to summary
public void onSubscribe(AbstractSubscription sub) Implements jdk.internal.net.http.ResponseContent.BodyParser.onSubscribe. Annotations @Override

onSubscribe

back to summary

public void onSubscribe(AbstractSubscription sub)

Implements jdk.internal.net.http.ResponseContent.BodyParser.onSubscribe.

Annotations

@Override

toDigit	back to summary
private int toDigit(int b) throws IOException

tryConsumeBytes	back to summary
private int tryConsumeBytes(ByteBuffer chunkbuf) throws IOException

tryPushOneHunk	back to summary
private boolean tryPushOneHunk(ByteBuffer b, List<ByteBuffer> out) throws IOException

tryReadChunkLen	back to summary
private int tryReadChunkLen(ByteBuffer chunkbuf) throws IOException

tryReadOneHunk	back to summary
pack-priv ByteBuffer tryReadOneHunk(ByteBuffer chunk) throws IOException Returns a ByteBuffer containing chunk of data or a "hunk" of data (a chunk of a chunk if the chunk size is larger than our ByteBuffers). If the given chunk does not have enough data this method return an empty ByteBuffer (READMORE). If we encounter the final chunk (an empty chunk) this method returns null.

jdk.internal.net.http back to summary

pack-priv final Enum ResponseContent.ChunkState

Class Inheritance

extends Enum<ResponseContent.ChunkState>

java.lang.Object
java.lang.Enum
jdk.internal.net.http.ResponseContent.ChunkState

Field Summary

Modifier and Type	Field and Description
public static final ResponseContent.ChunkState	DONE
public static final ResponseContent.ChunkState	READING_DATA
public static final ResponseContent.ChunkState	READING_LENGTH

Constructor Summary

Access	Constructor and Description
private	ChunkState()

Method Summary

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

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

Field Detail

DONE	back to summary
public static final ResponseContent.ChunkState DONE

READING_DATA	back to summary
public static final ResponseContent.ChunkState READING_DATA

READING_LENGTH	back to summary
public static final ResponseContent.ChunkState READING_LENGTH

Constructor Detail

ChunkState	back to summary
private ChunkState()

Method Detail

valueOf	back to summary
public static ResponseContent.ChunkState valueOf(String name)

values	back to summary
public static ResponseContent.ChunkState[] values()

jdk.internal.net.http back to summary

pack-priv Class ResponseContent.FixedLengthBodyParser

Class Inheritance

extends Object
implements BodyParser

java.lang.Object
jdk.internal.net.http.ResponseContent.FixedLengthBodyParser

All Implemented Interfaces

jdk.internal.net.http.ResponseContent.BodyParser, java.util.function.Consumer

Field Summary

Modifier and Type	Field and Description
pack-priv volatile Throwable	closedExceptionally
pack-priv final long	contentLength
pack-priv final String	dbgTag
pack-priv final Logger	debug
pack-priv final Consumer<Throwable>	onComplete
pack-priv volatile long	remaining
pack-priv volatile AbstractSubscription	sub

Constructor Summary

Access	Constructor and Description
pack-priv	FixedLengthBodyParser(long contentLength, Consumer<Throwable> onComplete)

Method Summary

Modifier and Type	Method and Description
public void	accept(ByteBuffer b) Implements java.util.function.Consumer.accept. Performs this operation on the given argument.
public String	currentStateMessage() Implements jdk.internal.net.http.ResponseContent.BodyParser.currentStateMessage.
pack-priv String	dbgString()
public void	onError(Throwable t) Implements jdk.internal.net.http.ResponseContent.BodyParser.onError.
public void	onSubscribe(AbstractSubscription sub) Implements jdk.internal.net.http.ResponseContent.BodyParser.onSubscribe.

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

Field Detail

closedExceptionally	back to summary
pack-priv volatile Throwable closedExceptionally

contentLength	back to summary
pack-priv final long contentLength

dbgTag	back to summary
pack-priv final String dbgTag

debug	back to summary
pack-priv final Logger debug

onComplete	back to summary
pack-priv final Consumer<Throwable> onComplete

remaining	back to summary
pack-priv volatile long remaining

sub	back to summary
pack-priv volatile AbstractSubscription sub

Constructor Detail

FixedLengthBodyParser	back to summary
pack-priv FixedLengthBodyParser(long contentLength, Consumer<Throwable> onComplete)

Method Detail

back to summary

public void accept(ByteBuffer b)

Implements java.util.function.Consumer.accept.

Doc from java.util.function.Consumer.accept.

Performs this operation on the given argument.

Annotations

@Override

currentStateMessage

back to summary

public String currentStateMessage()

Implements jdk.internal.net.http.ResponseContent.BodyParser.currentStateMessage.

Annotations

@Override

dbgString	back to summary
pack-priv String dbgString()

onError

back to summary

public void onError(Throwable t)

Implements jdk.internal.net.http.ResponseContent.BodyParser.onError.

Annotations

@Override

onSubscribe

back to summary

public void onSubscribe(AbstractSubscription sub)

Implements jdk.internal.net.http.ResponseContent.BodyParser.onSubscribe.

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv Class ResponseContent.UnknownLengthBodyParser

Class Inheritance

extends Object
implements BodyParser

java.lang.Object
jdk.internal.net.http.ResponseContent.UnknownLengthBodyParser

All Implemented Interfaces

jdk.internal.net.http.ResponseContent.BodyParser, java.util.function.Consumer

Field Summary

Modifier and Type	Field and Description
pack-priv volatile int	breceived
pack-priv volatile Throwable	closedExceptionally
pack-priv final String	dbgTag
pack-priv final Logger	debug
pack-priv final Consumer<Throwable>	onComplete
pack-priv volatile AbstractSubscription	sub

Constructor Summary

Access	Constructor and Description
pack-priv	UnknownLengthBodyParser(Consumer<Throwable> onComplete)

Method Summary

Modifier and Type	Method and Description
public void	accept(ByteBuffer b) Implements java.util.function.Consumer.accept. Performs this operation on the given argument.
public void	complete() Must be called externally when connection has closed and therefore no more bytes can be read
public String	currentStateMessage() Implements jdk.internal.net.http.ResponseContent.BodyParser.currentStateMessage.
pack-priv String	dbgString()
public void	onError(Throwable t) Implements jdk.internal.net.http.ResponseContent.BodyParser.onError.
public void	onSubscribe(AbstractSubscription sub) Implements jdk.internal.net.http.ResponseContent.BodyParser.onSubscribe.