Top Description Inners Fields Constructors Methods
jdk.internal.net.http

pack-priv Class PushGroup<T>

extends Object
Class Inheritance
Imports
java.util.Objects, java.util.concurrent.CompletableFuture, .Executor, java.net.http.HttpRequest, .HttpResponse, .HttpResponse.BodyHandler, .HttpResponse.PushPromiseHandler, java.util.concurrent.locks.ReentrantLock, jdk.internal.net.http.common.MinimalFuture, .Log
One PushGroup object is associated with the parent Stream of the pushed Streams. This keeps track of all common state associated with the pushes.

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static interface
PushGroup.Acceptor<T>

private static class
PushGroup.AcceptorImpl<T>

Field Summary

Modifier and TypeField and Description
pack-priv volatile Throwable
error

private final Executor
executor

private final HttpRequest
initiatingRequest

pack-priv int
numberOfPushes

pack-priv final HttpResponse.PushPromiseHandler<T>
pushPromiseHandler

pack-priv int
remainingPushes

private final ReentrantLock
stateLock

Constructor Summary

AccessConstructor and Description
pack-priv
PushGroup(HttpResponse.PushPromiseHandler<T> pushPromiseHandler, HttpRequestImpl initiatingRequest, Executor executor)

private
PushGroup(HttpResponse.PushPromiseHandler<T> pushPromiseHandler, HttpRequestImpl initiatingRequest, CompletableFuture<HttpResponse<T>> mainResponse, Executor executor)

Method Summary

Modifier and TypeMethod and Description
pack-priv PushGroup.Acceptor<T>
acceptPushRequest(HttpRequest pushRequest)

private void
checkIfCompleted()

pack-priv void
pushCompleted()

pack-priv void
pushError(Throwable t)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

errorback to summary
pack-priv volatile Throwable error
executorback to summary
private final Executor executor
initiatingRequestback to summary
private final HttpRequest initiatingRequest
numberOfPushesback to summary
pack-priv int numberOfPushes
pushPromiseHandlerback to summary
pack-priv final HttpResponse.PushPromiseHandler<T> pushPromiseHandler
remainingPushesback to summary
pack-priv int remainingPushes
stateLockback to summary
private final ReentrantLock stateLock

Constructor Detail

PushGroupback to summary
pack-priv PushGroup(HttpResponse.PushPromiseHandler<T> pushPromiseHandler, HttpRequestImpl initiatingRequest, Executor executor)
PushGroupback to summary
private PushGroup(HttpResponse.PushPromiseHandler<T> pushPromiseHandler, HttpRequestImpl initiatingRequest, CompletableFuture<HttpResponse<T>> mainResponse, Executor executor)

Method Detail

acceptPushRequestback to summary
pack-priv PushGroup.Acceptor<T> acceptPushRequest(HttpRequest pushRequest)
checkIfCompletedback to summary
private void checkIfCompleted()
pushCompletedback to summary
pack-priv void pushCompleted()
pushErrorback to summary
pack-priv void pushError(Throwable t)
jdk.internal.net.http back to summary

pack-priv Interface PushGroup.Acceptor<T>

Known Direct Implementers
jdk.internal.net.http.PushGroup.AcceptorImpl

Method Summary

Modifier and TypeMethod and Description
public boolean
accepted()

public HttpResponse.BodyHandler<T>
bodyHandler()

public CompletableFuture<HttpResponse<T>>
cf()

Method Detail

acceptedback to summary
public boolean accepted()
bodyHandlerback to summary
public HttpResponse.BodyHandler<T> bodyHandler()
cfback to summary
public CompletableFuture<HttpResponse<T>> cf()
jdk.internal.net.http back to summary

private Class PushGroup.AcceptorImpl<T>

extends Object
implements PushGroup.Acceptor<T>
Class Inheritance
All Implemented Interfaces
jdk.internal.net.http.PushGroup.Acceptor

Field Summary

Modifier and TypeField and Description
private volatile HttpResponse.BodyHandler<T>
bodyHandler

private volatile CompletableFuture<HttpResponse<T>>
cf

private final Executor
executor

Constructor Summary

AccessConstructor and Description
pack-priv
AcceptorImpl(Executor executor)

Method Summary

Modifier and TypeMethod and Description
pack-priv CompletableFuture<HttpResponse<T>>
accept(HttpResponse.BodyHandler<T> bodyHandler)

public boolean
accepted()

Implements jdk.internal.net.http.PushGroup.Acceptor.accepted.

public HttpResponse.BodyHandler<T>
bodyHandler()

Implements jdk.internal.net.http.PushGroup.Acceptor.bodyHandler.

public CompletableFuture<HttpResponse<T>>
cf()

Implements jdk.internal.net.http.PushGroup.Acceptor.cf.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

bodyHandlerback to summary
private volatile HttpResponse.BodyHandler<T> bodyHandler
cfback to summary
private volatile CompletableFuture<HttpResponse<T>> cf
executorback to summary
private final Executor executor

Constructor Detail

AcceptorImplback to summary
pack-priv AcceptorImpl(Executor executor)

Method Detail

acceptback to summary
pack-priv CompletableFuture<HttpResponse<T>> accept(HttpResponse.BodyHandler<T> bodyHandler)
acceptedback to summary
public boolean accepted()

Implements jdk.internal.net.http.PushGroup.Acceptor.accepted.

Annotations
@Override
bodyHandlerback to summary
public HttpResponse.BodyHandler<T> bodyHandler()

Implements jdk.internal.net.http.PushGroup.Acceptor.bodyHandler.

Annotations
@Override
cfback to summary
public CompletableFuture<HttpResponse<T>> cf()

Implements jdk.internal.net.http.PushGroup.Acceptor.cf.

Annotations
@Override