| Modifier and Type | Class and Description |
|---|---|
| pack-priv class | |
| private static class | |
| pack-priv class | |
| pack-priv abstract static class | |
| pack-priv static enum |
| Modifier and Type | Field and Description |
|---|---|
| private final Http1AsyncReceiver | |
| private volatile ResponseContent. | |
| private final Http1Response | |
| private volatile boolean | |
| private final HttpConnection | |
| private volatile ResponseContent | |
| pack-priv String | |
| pack-priv final Logger | |
| private volatile EOFException | |
| private final Http1Exchange | |
| private boolean | |
| private volatile boolean | |
| private Http1HeaderParser | |
| private HttpHeaders | |
| private final Http1Response | |
| pack-priv final long | |
| private static final int | |
| private volatile Http1Response. | |
| private final HttpRequestImpl | |
| private Response | |
| private int | |
| pack-priv static final AtomicLong | |
| private boolean |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| private Http1Response. | |
| pack-priv void | |
| pack-priv synchronized void | |
| private String | |
| pack-priv synchronized boolean | |
| pack-priv long | fixupContentLen(long clen)
Return known fixed content length or -1 if chunked, or -2 if no content-length information in which case, connection termination delimits the response body |
| public CompletableFuture | |
| public void | |
| private void | |
| pack-priv void | |
| public <U> CompletableFuture | |
| public CompletableFuture | |
| pack-priv Http1Response. | |
| pack-priv int | |
| pack-priv HttpHeaders |
| asyncReceiver | back to summary |
|---|---|
| private final Http1AsyncReceiver asyncReceiver | |
| bodyParser | back to summary |
|---|---|
| private volatile ResponseContent. | |
| bodyReader | back to summary |
|---|---|
| private final Http1Response<T>. | |
| closeWhenFinished | back to summary |
|---|---|
| private volatile boolean closeWhenFinished | |
| connection | back to summary |
|---|---|
| private final HttpConnection connection | |
| content | back to summary |
|---|---|
| private volatile ResponseContent content | |
| dbgTag | back to summary |
|---|---|
| pack-priv String dbgTag | |
| debug | back to summary |
|---|---|
| pack-priv final Logger debug | |
| eof | back to summary |
|---|---|
| private volatile EOFException eof | |
| exchange | back to summary |
|---|---|
| private final Http1Exchange<T> exchange | |
| finished | back to summary |
|---|---|
| private boolean finished | |
| firstTimeAround | back to summary |
|---|---|
| private volatile boolean firstTimeAround | |
| hd | back to summary |
|---|---|
| private Http1HeaderParser hd | |
| headers | back to summary |
|---|---|
| private HttpHeaders headers | |
| headersReader | back to summary |
|---|---|
| private final Http1Response<T>. | |
| id | back to summary |
|---|---|
| pack-priv final long id | |
| MAX_IGNORE | back to summary |
|---|---|
| private static final int MAX_IGNORE | |
| readProgress | back to summary |
|---|---|
| private volatile Http1Response. | |
| request | back to summary |
|---|---|
| private final HttpRequestImpl request | |
| response | back to summary |
|---|---|
| private Response response | |
| responseCode | back to summary |
|---|---|
| private int responseCode | |
| responseCount | back to summary |
|---|---|
| pack-priv static final AtomicLong responseCount | |
| return2Cache | back to summary |
|---|---|
| private boolean return2Cache | |
| Http1Response | back to summary |
|---|---|
| pack-priv Http1Response(HttpConnection conn, Http1Exchange<T> exchange, Http1AsyncReceiver asyncReceiver) | |
| advance | back to summary |
|---|---|
| private Http1Response. | |
| closeWhenFinished | back to summary |
|---|---|
| pack-priv void closeWhenFinished() | |
| completed | back to summary |
|---|---|
| pack-priv synchronized void completed() | |
| dbgString | back to summary |
|---|---|
| private String dbgString() | |
| finished | back to summary |
|---|---|
| pack-priv synchronized boolean finished() | |
| fixupContentLen | back to summary |
|---|---|
| pack-priv long fixupContentLen(long clen) Return known fixed content length or -1 if chunked, or -2 if no content-length information in which case, connection termination delimits the response body | |
| ignoreBody | back to summary |
|---|---|
| public CompletableFuture Reads the body, if it is present and less than 1024 bytes. Otherwise, just the connection is closed. | |
| nullBody | back to summary |
|---|---|
| public void nullBody(HttpResponse<T> resp, Throwable t) | |
| onFinished | back to summary |
|---|---|
| private void onFinished() | |
| onReadError | back to summary |
|---|---|
| pack-priv void onReadError(Throwable t) | |
| readBody | back to summary |
|---|---|
| public <U> CompletableFuture | |
| readHeadersAsync | back to summary |
|---|---|
| public CompletableFuture | |
| receiver | back to summary |
|---|---|
| pack-priv Http1Response. | |
| responseCode | back to summary |
|---|---|
| pack-priv int responseCode() | |
| responseHeaders | back to summary |
|---|---|
| pack-priv HttpHeaders responseHeaders() | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv volatile CompletableFuture | |
| pack-priv final Consumer | |
| pack-priv volatile ResponseContent. | |
| pack-priv volatile AbstractSubscription |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| cf | back to summary |
|---|---|
| pack-priv volatile CompletableFuture<Http1Response. | |
| onComplete | back to summary |
|---|---|
| pack-priv final Consumer<Http1Response. | |
| parser | back to summary |
|---|---|
| pack-priv volatile ResponseContent. | |
| subscription | back to summary |
|---|---|
| pack-priv volatile AbstractSubscription subscription | |
| BodyReader | back to summary |
|---|---|
| pack-priv BodyReader(Consumer<Http1Response. | |
| close | back to summary |
|---|---|
| public final void close(Throwable error) Implements jdk. Doc from jdk. Called to make sure resources are released when the Http1AsyncReceiver is stopped.
| |
| completion | back to summary |
|---|---|
| pack-priv CompletableFuture Implements abstract jdk.
| |
| handle | back to summary |
|---|---|
| pack-priv final void handle(ByteBuffer b, ResponseContent. Implements abstract jdk.
| |
| onComplete | back to summary |
|---|---|
| pack-priv final void onComplete(Throwable closedExceptionally) | |
| onReadError | back to summary |
|---|---|
| public final void onReadError(Throwable t) Implements abstract jdk. Implements jdk. Doc from jdk. Called when an exception is raised.
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(AbstractSubscription s) Implements abstract jdk. Implements jdk. Doc from jdk. Must be called before any other method on the delegate.
The subscription can be either used directly by the delegate
to request more data (e.g. if the delegate is a header parser),
or can be forwarded to a downstream subscriber (if the delegate
is a body parser that wraps a response BodySubscriber).
In all cases, it is the responsibility of the delegate to ensure
that request(n) and demand.tryDecrement() are called appropriately.
No data will be sent to
| |
| reset | back to summary |
|---|---|
| pack-priv void reset() Implements abstract jdk.
| |
| start | back to summary |
|---|---|
| pack-priv final void start(ResponseContent. Implements abstract jdk.
| |
| subscription | back to summary |
|---|---|
| public AbstractSubscription subscription() Implements abstract jdk. Implements jdk. Doc from jdk. Returns the subscription that was passed to
| |
| toString | back to summary |
|---|---|
| public String toString() Overrides java. Doc from java. Returns a string representation of the object.
Satisfying this method's contract implies a non-
| |
| tryAsyncReceive | back to summary |
|---|---|
| public final boolean tryAsyncReceive(ByteBuffer b) Implements abstract jdk. Implements jdk. Doc from jdk. Receives and handles a byte buffer reference.
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final HttpClientImpl | |
| pack-priv final Logger | |
| pack-priv volatile byte | |
| private static final VarHandle |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public boolean | |
| public void |
| client | back to summary |
|---|---|
| pack-priv final HttpClientImpl client | |
| debug | back to summary |
|---|---|
| pack-priv final Logger debug | |
| state | back to summary |
|---|---|
| pack-priv volatile byte state | |
| STATE | back to summary |
|---|---|
| private static final VarHandle STATE | |
| ClientRefCountTracker | back to summary |
|---|---|
| pack-priv ClientRefCountTracker(HttpClientImpl client, Logger logger) | |
| acquire | back to summary |
|---|---|
| public boolean acquire() | |
| tryRelease | back to summary |
|---|---|
| public void tryRelease() | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv volatile CompletableFuture | |
| pack-priv volatile long | |
| pack-priv final Consumer | |
| pack-priv volatile Http1HeaderParser | |
| pack-priv volatile AbstractSubscription |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| cf | back to summary |
|---|---|
| pack-priv volatile CompletableFuture<Http1Response. | |
| count | back to summary |
|---|---|
| pack-priv volatile long count | |
| onComplete | back to summary |
|---|---|
| pack-priv final Consumer<Http1Response. | |
| parser | back to summary |
|---|---|
| pack-priv volatile Http1HeaderParser parser | |
| subscription | back to summary |
|---|---|
| pack-priv volatile AbstractSubscription subscription | |
| HeadersReader | back to summary |
|---|---|
| pack-priv HeadersReader(Consumer<Http1Response. | |
| close | back to summary |
|---|---|
| public void close(Throwable error) Implements jdk. Doc from jdk. Called to make sure resources are released when the Http1AsyncReceiver is stopped.
| |
| completion | back to summary |
|---|---|
| pack-priv CompletableFuture Implements abstract jdk.
| |
| handle | back to summary |
|---|---|
| pack-priv final void handle(ByteBuffer b, Http1HeaderParser parser, CompletableFuture<Http1Response. Implements abstract jdk.
| |
| onReadError | back to summary |
|---|---|
| public final void onReadError(Throwable t) Implements abstract jdk. Implements jdk. Doc from jdk. Called when an exception is raised.
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(AbstractSubscription s) Implements abstract jdk. Implements jdk. Doc from jdk. Must be called before any other method on the delegate.
The subscription can be either used directly by the delegate
to request more data (e.g. if the delegate is a header parser),
or can be forwarded to a downstream subscriber (if the delegate
is a body parser that wraps a response BodySubscriber).
In all cases, it is the responsibility of the delegate to ensure
that request(n) and demand.tryDecrement() are called appropriately.
No data will be sent to
| |
| reset | back to summary |
|---|---|
| pack-priv void reset() Implements abstract jdk.
| |
| start | back to summary |
|---|---|
| pack-priv final void start(Http1HeaderParser hp) Implements abstract jdk.
| |
| subscription | back to summary |
|---|---|
| public AbstractSubscription subscription() Implements abstract jdk. Implements jdk. Doc from jdk. Returns the subscription that was passed to
| |
| tryAsyncReceive | back to summary |
|---|---|
| public final boolean tryAsyncReceive(ByteBuffer ref) Implements abstract jdk. Implements jdk. Doc from jdk. Receives and handles a byte buffer reference.
| |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv final boolean | |
| pack-priv abstract CompletableFuture | |
| pack-priv abstract void | |
| public abstract void | onReadError(Throwable t)
Redeclares jdk. Called when an exception is raised. |
| public abstract void | onSubscribe(AbstractSubscription s)
Redeclares jdk. Must be called before any other method on the delegate. |
| pack-priv abstract void | |
| pack-priv abstract void | |
| public abstract AbstractSubscription | subscription()
Redeclares jdk. Returns the subscription that was passed to |
| public abstract boolean | tryAsyncReceive(ByteBuffer buffer)
Redeclares jdk. Receives and handles a byte buffer reference. |
| Receiver | back to summary |
|---|---|
| pack-priv Receiver() | |
| accept | back to summary |
|---|---|
| pack-priv final boolean accept(ByteBuffer buf, T parser, CompletableFuture<Http1Response. | |
| completion | back to summary |
|---|---|
| pack-priv abstract CompletableFuture | |
| handle | back to summary |
|---|---|
| pack-priv abstract void handle(ByteBuffer buf, T parser, CompletableFuture<Http1Response. | |
| onReadError | back to summary |
|---|---|
| public abstract void onReadError(Throwable t) Redeclares jdk. Doc from jdk. Called when an exception is raised. | |
| onSubscribe | back to summary |
|---|---|
| public abstract void onSubscribe(AbstractSubscription s) Redeclares jdk. Doc from jdk. Must be called before any other method on the delegate.
The subscription can be either used directly by the delegate
to request more data (e.g. if the delegate is a header parser),
or can be forwarded to a downstream subscriber (if the delegate
is a body parser that wraps a response BodySubscriber).
In all cases, it is the responsibility of the delegate to ensure
that request(n) and demand.tryDecrement() are called appropriately.
No data will be sent to | |
| reset | back to summary |
|---|---|
| pack-priv abstract void reset() | |
| start | back to summary |
|---|---|
| pack-priv abstract void start(T parser) | |
| subscription | back to summary |
|---|---|
| public abstract AbstractSubscription subscription() Redeclares jdk. Doc from jdk. Returns the subscription that was passed to | |
| tryAsyncReceive | back to summary |
|---|---|
| public abstract boolean tryAsyncReceive(ByteBuffer buffer) Redeclares jdk. Doc from jdk. Receives and handles a byte buffer reference. | |
| Modifier and Type | Field and Description |
|---|---|
| public static final Http1Response. | |
| public static final Http1Response. | |
| public static final Http1Response. | |
| public static final Http1Response. |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public static Http1Response. | |
| public static Http1Response. |
| DONE | back to summary |
|---|---|
| public static final Http1Response. | |
| INITIAL | back to summary |
|---|---|
| public static final Http1Response. | |
| READING_BODY | back to summary |
|---|---|
| public static final Http1Response. | |
| READING_HEADERS | back to summary |
|---|---|
| public static final Http1Response. | |
| State | back to summary |
|---|---|
| private State() | |
| valueOf | back to summary |
|---|---|
| public static Http1Response. | |
| values | back to summary |
|---|---|
| public static Http1Response. | |