Modifier and Type	Class and Description
pack-priv class	Http1Request.FixedContentSubscriber
pack-priv class	Http1Request.StreamSubscriber

Field Summary

Modifier and Type	Field and Description
private final HttpConnection	connection
private volatile long	contentLength
private static final String	COOKIE_HEADER
private static final byte[]	CRLF
pack-priv final Logger	debug
private static final byte[]	EMPTY_CHUNK_BYTES
private boolean	finished
private final Http1Exchange<?>	http1Exchange
private static final BiPredicate<String, String>	NOCOOKIES
private final HttpRequestImpl	request
private final HttpRequest.BodyPublisher	requestPublisher
private volatile boolean	streaming
private final HttpHeadersBuilder	systemHeadersBuilder
private volatile HttpHeaders	userHeaders

Constructor Summary

Access	Constructor and Description
pack-priv	Http1Request(HttpRequestImpl request, Http1Exchange<?> http1Exchange)

Method Summary

Modifier and Type	Method and Description
private String	authorityString(InetSocketAddress addr)
private void	collectCookies(StringBuilder sb, HttpHeaders system, HttpHeaders user)
public void	collectHeaders0(StringBuilder sb)
private void	collectHeaders1(StringBuilder sb, HttpHeaders headers, BiPredicate<String, String> filter)
pack-priv Http1Exchange.Http1RequestBodySubscriber	continueRequest()
pack-priv synchronized boolean	finished()
private static ByteBuffer	getHeader(int size) Returns a header for a particular chunk size
private String	getPathAndQuery(URI uri)
pack-priv List<ByteBuffer>	headers()
private String	hostString()
private void	logHeaders(String completeHeaders)
private String	requestURI()
pack-priv synchronized void	setFinished()

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

Field Detail

connection	back to summary
private final HttpConnection connection

contentLength	back to summary
private volatile long contentLength

COOKIE_HEADER	back to summary
private static final String COOKIE_HEADER

CRLF	back to summary
private static final byte[] CRLF

debug	back to summary
pack-priv final Logger debug

EMPTY_CHUNK_BYTES	back to summary
private static final byte[] EMPTY_CHUNK_BYTES

finished	back to summary
private boolean finished

http1Exchange	back to summary
private final Http1Exchange<?> http1Exchange

NOCOOKIES	back to summary
private static final BiPredicate<String, String> NOCOOKIES

request	back to summary
private final HttpRequestImpl request

requestPublisher	back to summary
private final HttpRequest.BodyPublisher requestPublisher

streaming	back to summary
private volatile boolean streaming

systemHeadersBuilder	back to summary
private final HttpHeadersBuilder systemHeadersBuilder

userHeaders	back to summary
private volatile HttpHeaders userHeaders

Constructor Detail

Http1Request	back to summary
pack-priv Http1Request(HttpRequestImpl request, Http1Exchange<?> http1Exchange) throws IOException

Method Detail

authorityString	back to summary
private String authorityString(InetSocketAddress addr)

collectCookies	back to summary
private void collectCookies(StringBuilder sb, HttpHeaders system, HttpHeaders user)

collectHeaders0	back to summary
public void collectHeaders0(StringBuilder sb)

collectHeaders1	back to summary
private void collectHeaders1(StringBuilder sb, HttpHeaders headers, BiPredicate<String, String> filter)

continueRequest	back to summary
pack-priv Http1Exchange.Http1RequestBodySubscriber continueRequest()

finished	back to summary
pack-priv synchronized boolean finished()

getHeader	back to summary
private static ByteBuffer getHeader(int size) Returns a header for a particular chunk size

getPathAndQuery	back to summary
private String getPathAndQuery(URI uri)

headers	back to summary
pack-priv List<ByteBuffer> headers()

hostString	back to summary
private String hostString()

logHeaders	back to summary
private void logHeaders(String completeHeaders)

requestURI	back to summary
private String requestURI()

setFinished	back to summary
pack-priv synchronized void setFinished()

jdk.internal.net.http back to summary

pack-priv final Class Http1Request.FixedContentSubscriber

Class Inheritance

extends Http1RequestBodySubscriber

java.lang.Object
jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber
jdk.internal.net.http.Http1Request.FixedContentSubscriber

Field Summary

Modifier and Type	Field and Description
private volatile long	contentWritten

Inherited from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber:: complete COMPLETED whenSubscribed

Constructor Summary

Access	Constructor and Description
pack-priv	FixedContentSubscriber()

Method Summary

Modifier and Type	Method and Description
public String	currentStateMessage() Implements abstract jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage. A current-state message suitable for inclusion in an exception detail message.
public void	onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
public void	onError(Throwable throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
public void	onNext(ByteBuffer item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.

Inherited from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber:: cancelSubscription completeSubscriber isSubscribed request setSubscription

Field Detail

contentWritten	back to summary
private volatile long contentWritten

Constructor Detail

FixedContentSubscriber	back to summary
pack-priv FixedContentSubscriber()

Method Detail

currentStateMessage	back to summary
public String currentStateMessage() Implements abstract jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage. Doc from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage. A current-state message suitable for inclusion in an exception detail message. Annotations @Override

currentStateMessage

back to summary

public String currentStateMessage()

Implements abstract jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage.

Doc from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage.

A current-state message suitable for inclusion in an exception detail message.

Annotations

@Override

onComplete	back to summary
public void onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Doc from java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined. Annotations @Override

onComplete

back to summary

public void onComplete()

Implements java.util.concurrent.Flow.Subscriber.onComplete.

Doc from java.util.concurrent.Flow.Subscriber.onComplete.

Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined.

Annotations

@Override

onError	back to summary
public void onError(Throwable throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Doc from java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined. Annotations @Override

onError

back to summary

public void onError(Throwable throwable)

Implements java.util.concurrent.Flow.Subscriber.onError.

Doc from java.util.concurrent.Flow.Subscriber.onError.

Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined.

Annotations

@Override

onNext	back to summary
public void onNext(ByteBuffer item) Implements java.util.concurrent.Flow.Subscriber.onNext. Doc from java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled. Annotations @Override

onNext

back to summary

public void onNext(ByteBuffer item)

Implements java.util.concurrent.Flow.Subscriber.onNext.

Doc from java.util.concurrent.Flow.Subscriber.onNext.

Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Doc from java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled. Typically, implementations of this method invoke `subscription.request` to enable receiving items. Annotations @Override

public void onSubscribe(Flow.Subscription subscription)

Implements java.util.concurrent.Flow.Subscriber.onSubscribe.

Doc from java.util.concurrent.Flow.Subscriber.onSubscribe.

Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled.

Typically, implementations of this method invoke subscription.request to enable receiving items.

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv final Class Http1Request.StreamSubscriber

Class Inheritance

extends Http1RequestBodySubscriber

java.lang.Object
jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber
jdk.internal.net.http.Http1Request.StreamSubscriber

Field Summary

Inherited from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber:: complete COMPLETED whenSubscribed

Constructor Summary

Access	Constructor and Description
pack-priv	StreamSubscriber()

Method Summary

Modifier and Type	Method and Description
public String	currentStateMessage() Implements abstract jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage. A current-state message suitable for inclusion in an exception detail message.
public void	onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
public void	onError(Throwable throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
public void	onNext(ByteBuffer item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.

Inherited from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber:: cancelSubscription completeSubscriber isSubscribed request setSubscription

Constructor Detail

StreamSubscriber	back to summary
pack-priv StreamSubscriber()

Method Detail

currentStateMessage	back to summary
public String currentStateMessage() Implements abstract jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage. Doc from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage. A current-state message suitable for inclusion in an exception detail message. Annotations @Override

currentStateMessage

back to summary

public String currentStateMessage()

Implements abstract jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage.

Doc from jdk.internal.net.http.Http1Exchange.Http1RequestBodySubscriber.currentStateMessage.

A current-state message suitable for inclusion in an exception detail message.

Annotations

@Override

onComplete	back to summary
public void onComplete() Implements java.util.concurrent.Flow.Subscriber.onComplete. Doc from java.util.concurrent.Flow.Subscriber.onComplete. Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined. Annotations @Override

onComplete

back to summary

public void onComplete()

Implements java.util.concurrent.Flow.Subscriber.onComplete.

Doc from java.util.concurrent.Flow.Subscriber.onComplete.

Annotations

@Override

onError	back to summary
public void onError(Throwable throwable) Implements java.util.concurrent.Flow.Subscriber.onError. Doc from java.util.concurrent.Flow.Subscriber.onError. Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined. Annotations @Override

onError

back to summary

public void onError(Throwable throwable)

Implements java.util.concurrent.Flow.Subscriber.onError.

Doc from java.util.concurrent.Flow.Subscriber.onError.

Annotations

@Override

onNext	back to summary
public void onNext(ByteBuffer item) Implements java.util.concurrent.Flow.Subscriber.onNext. Doc from java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled. Annotations @Override

onNext

back to summary

public void onNext(ByteBuffer item)

Implements java.util.concurrent.Flow.Subscriber.onNext.

Doc from java.util.concurrent.Flow.Subscriber.onNext.

Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.

Annotations

@Override

onSubscribe back to summary

onSubscribe	back to summary
public void onSubscribe(Flow.Subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Doc from java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled. Typically, implementations of this method invoke `subscription.request` to enable receiving items. Annotations @Override

public void onSubscribe(Flow.Subscription subscription)

Implements java.util.concurrent.Flow.Subscriber.onSubscribe.

Doc from java.util.concurrent.Flow.Subscriber.onSubscribe.

Typically, implementations of this method invoke subscription.request to enable receiving items.

Annotations

@Override

pack-priv Class Http1Request

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class Http1Request.FixedContentSubscriber

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class Http1Request.StreamSubscriber

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail