Modifier and Type	Class and Description
private class	HttpBodySubscriberWrapper.SubscriptionWrapper

Modifier and Type	Field and Description
pack-priv static final int	CANCELLED
public static final Comparator<HttpBodySubscriberWrapper<?>>	COMPARE_BY_ID
pack-priv static final int	COMPLETED
pack-priv final long	id
pack-priv static final AtomicLong	IDS
public static final Flow.Subscription	NOP
pack-priv static final int	REGISTERED
private volatile int	state
pack-priv static final int	SUBSCRIBED
pack-priv volatile HttpBodySubscriberWrapper<T>.SubscriptionWrapper	subscription
pack-priv final ReentrantLock	subscriptionLock
pack-priv static final int	UNREGISTERED
pack-priv final HttpResponse.BodySubscriber<T>	userSubscriber
pack-priv volatile Throwable	withError

Access	Constructor and Description
public	HttpBodySubscriberWrapper(HttpResponse.BodySubscriber<T> userSubscriber)

Method Summary

Modifier and Type	Method and Description
public final boolean	Returns: true if this subscriber's subscription has already been cancelled cancelled() Returns true if this subscriber's subscription has already been cancelled.
public final void	complete(Throwable a throwable, or `null` t) Complete the subscriber, either normally or exceptionally ensure that the subscriber is completed only once.
public final boolean	Returns: true if this subscriber has already completed, either normally or abnormally completed() Returns true if this subscriber has already completed, either normally or abnormally.
public CompletionStage<T>	getBody() Implements java.net.http.HttpResponse.BodySubscriber.getBody. Returns a `CompletionStage` which when completed will return the response body object.
pack-priv final long	id()
protected void	logComplete(Throwable error)
private boolean	markCancelled()
private boolean	markCompleted()
private boolean	markRegistered()
private final boolean	markState(final int flag)
private boolean	markSubscribed()
private boolean	markUnregistered()
public boolean	needsExecutor() Overrides default jdk.internal.net.http.ResponseSubscribers.TrustedSubscriber.needsExecutor. Returns true if getBody() should be called asynchronously.
protected void	onCancel() Called when the subscriber cancels its subscription.
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(List<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.
protected void	onTermination() A callback to be invoked before termination, whether due to the completion or failure of the subscriber, or cancellation of the subscription.
private void	propagateError(Throwable t)
protected void	register() This method can be implemented by subclasses to perform registration actions.
public final boolean	Returns: true if this subscriber has already been registered registered() Returns true if this subscriber has already been registered.
public final boolean	Returns: true if this subscriber has already subscribed subscribed() Returns true if this subscriber has already subscribed.
protected final boolean	Returns: `true` if `register()` was called, false otherwise. tryRegister() This method attempts to mark the state of this object as registered, and then call the `register()` method.
protected final boolean	Returns: `true` if `unregister()` was called, false otherwise. tryUnregister() This method attempts to mark the state of this object as unregistered, and then call the `unregister()` method.
protected void	unregister() This method can be implemented by subclasses to perform unregistration actions.
public final boolean	Returns: true if this subscriber has already been unregistered unregistered() Returns true if this subscriber has already been unregistered.

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

Field Detail

CANCELLED	back to summary
pack-priv static final int CANCELLED

COMPARE_BY_ID	back to summary
public static final Comparator<HttpBodySubscriberWrapper<?>> COMPARE_BY_ID

COMPLETED	back to summary
pack-priv static final int COMPLETED

id	back to summary
pack-priv final long id

IDS	back to summary
pack-priv static final AtomicLong IDS

NOP	back to summary
public static final Flow.Subscription NOP

REGISTERED	back to summary
pack-priv static final int REGISTERED

state	back to summary
private volatile int state

SUBSCRIBED	back to summary
pack-priv static final int SUBSCRIBED

subscription	back to summary
pack-priv volatile HttpBodySubscriberWrapper<T>.SubscriptionWrapper subscription

subscriptionLock	back to summary
pack-priv final ReentrantLock subscriptionLock

UNREGISTERED	back to summary
pack-priv static final int UNREGISTERED

userSubscriber	back to summary
pack-priv final HttpResponse.BodySubscriber<T> userSubscriber

withError	back to summary
pack-priv volatile Throwable withError

Constructor Detail

HttpBodySubscriberWrapper	back to summary
public HttpBodySubscriberWrapper(HttpResponse.BodySubscriber<T> userSubscriber)

Method Detail

cancelled	back to summary
public final boolean cancelled() Returns true if this subscriber's subscription has already been cancelled. Returns:boolean true if this subscriber's subscription has already been cancelled

cancelled

back to summary

public final boolean cancelled()

Returns true if this subscriber's subscription has already been cancelled.

Returns:boolean: true if this subscriber's subscription has already been cancelled

complete back to summary

complete	back to summary
public final void complete(Throwable t) Complete the subscriber, either normally or exceptionally ensure that the subscriber is completed only once. Implementation Specification If not completed() yet, this method calls `tryUnregister()` Parameters t:Throwable a throwable, or `null`

public final void complete(Throwable t)

Complete the subscriber, either normally or exceptionally ensure that the subscriber is completed only once.

Implementation Specification

If not completed() yet, this method calls tryUnregister()

Parameters

t:Throwable: a throwable, or null

completed	back to summary
public final boolean completed() Returns true if this subscriber has already completed, either normally or abnormally. Returns:boolean true if this subscriber has already completed, either normally or abnormally

completed

back to summary

public final boolean completed()

Returns true if this subscriber has already completed, either normally or abnormally.

Returns:boolean: true if this subscriber has already completed, either normally or abnormally

getBody back to summary

getBody	back to summary
public CompletionStage<T> getBody() Implements java.net.http.HttpResponse.BodySubscriber.getBody. Doc from java.net.http.HttpResponse.BodySubscriber.getBody. Returns a `CompletionStage` which when completed will return the response body object. This method can be called at any time relative to the other `Flow.Subscriber` methods and is invoked using the client's executor. Annotations @Override

public CompletionStage<T> getBody()

Implements java.net.http.HttpResponse.BodySubscriber.getBody.

Doc from java.net.http.HttpResponse.BodySubscriber.getBody.

Returns a CompletionStage which when completed will return the response body object. This method can be called at any time relative to the other Flow.Subscriber methods and is invoked using the client's executor.

Annotations

@Override

id	back to summary
pack-priv final long id()

logComplete	back to summary
protected void logComplete(Throwable error)

markCancelled	back to summary
private boolean markCancelled()

markCompleted	back to summary
private boolean markCompleted()

markRegistered	back to summary
private boolean markRegistered()

markState	back to summary
private final boolean markState(final int flag)

markSubscribed	back to summary
private boolean markSubscribed()

markUnregistered	back to summary
private boolean markUnregistered()

needsExecutor	back to summary
public boolean needsExecutor() Overrides default jdk.internal.net.http.ResponseSubscribers.TrustedSubscriber.needsExecutor. Doc from jdk.internal.net.http.ResponseSubscribers.TrustedSubscriber.needsExecutor. Returns true if getBody() should be called asynchronously. Annotations @Override

needsExecutor

back to summary

public boolean needsExecutor()

Overrides default jdk.internal.net.http.ResponseSubscribers.TrustedSubscriber.needsExecutor.

Doc from jdk.internal.net.http.ResponseSubscribers.TrustedSubscriber.needsExecutor.

Returns true if getBody() should be called asynchronously.

Annotations

@Override

onCancel	back to summary
protected void onCancel() Called when the subscriber cancels its subscription. API Note This method may be used by subclasses to perform cleanup actions after a subscription has been cancelled. Implementation Specification This method calls `tryUnregister()`

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(List<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(List<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

onTermination	back to summary
protected void onTermination() A callback to be invoked before termination, whether due to the completion or failure of the subscriber, or cancellation of the subscription. To be precise, this method is called before `onComplete()`, `onError()`, or `onCancel()`.

propagateError	back to summary
private void propagateError(Throwable t)

register	back to summary
protected void register() This method can be implemented by subclasses to perform registration actions. It will not be called if already registered or unregistered. API Note This method is called while holding a subscription lock. See Also `tryRegister()`

protected void register()

This method can be implemented by subclasses to perform registration actions. It will not be called if already registered or unregistered.

API Note

This method is called while holding a subscription lock.

See Also: tryRegister()

registered	back to summary
public final boolean registered() Returns true if this subscriber has already been registered. Returns:boolean true if this subscriber has already been registered

registered

back to summary

public final boolean registered()

Returns true if this subscriber has already been registered.

Returns:boolean: true if this subscriber has already been registered

subscribed	back to summary
public final boolean subscribed() Returns true if this subscriber has already subscribed. Returns:boolean true if this subscriber has already subscribed

subscribed

back to summary

public final boolean subscribed()

Returns true if this subscriber has already subscribed.

Returns:boolean: true if this subscriber has already subscribed

tryRegister back to summary

tryRegister	back to summary
protected final boolean tryRegister() This method attempts to mark the state of this object as registered, and then call the `register()` method. The state will be marked as registered, and the `register()` method will be called only if not already registered or unregistered, or cancelled, or completed. Returns:boolean `true` if `register()` was called, false otherwise.

protected final boolean tryRegister()

This method attempts to mark the state of this object as registered, and then call the register() method.

The state will be marked as registered, and the register() method will be called only if not already registered or unregistered, or cancelled, or completed.

Returns:boolean: true if register() was called, false otherwise.

tryUnregister back to summary

tryUnregister	back to summary
protected final boolean tryUnregister() This method attempts to mark the state of this object as unregistered, and then call the `unregister()` method. The `unregister()` method will be called only if already registered and not yet unregistered. Whether `unregister()` is called or not, the state is marked as unregistered, to prevent `tryRegister()` from calling `register()` after `tryUnregister()` has been called. Returns:boolean `true` if `unregister()` was called, false otherwise.

protected final boolean tryUnregister()

This method attempts to mark the state of this object as unregistered, and then call the unregister() method.

The unregister() method will be called only if already registered and not yet unregistered. Whether unregister() is called or not, the state is marked as unregistered, to prevent tryRegister() from calling register() after tryUnregister() has been called.

Returns:boolean: true if unregister() was called, false otherwise.

unregister back to summary

unregister	back to summary
protected void unregister() This method can be implemented by subclasses to perform unregistration actions. It will not be called if not already registered, or already unregistered. API Note This method is called while holding a subscription lock. See Also `tryUnregister()`

protected void unregister()

This method can be implemented by subclasses to perform unregistration actions. It will not be called if not already registered, or already unregistered.

API Note

This method is called while holding a subscription lock.

See Also: tryUnregister()

unregistered	back to summary
public final boolean unregistered() Returns true if this subscriber has already been unregistered. Returns:boolean true if this subscriber has already been unregistered

unregistered

back to summary

public final boolean unregistered()

Returns true if this subscriber has already been unregistered.

Returns:boolean: true if this subscriber has already been unregistered

jdk.internal.net.http.common back to summary

private final Class HttpBodySubscriberWrapper.SubscriptionWrapper

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.common.HttpBodySubscriberWrapper.SubscriptionWrapper

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Field Summary

Modifier and Type	Field and Description
pack-priv final Flow.Subscription	subscription

Constructor Summary

Access	Constructor and Description
pack-priv	SubscriptionWrapper(Flow.Subscription s)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements java.util.concurrent.Flow.Subscription.cancel. Causes the Subscriber to (eventually) stop receiving messages.
public void	request(long n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.

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

Field Detail

subscription	back to summary
pack-priv final Flow.Subscription subscription

Constructor Detail

SubscriptionWrapper	back to summary
pack-priv SubscriptionWrapper(Flow.Subscription s)

Method Detail

cancel back to summary

public void cancel()

Implements java.util.concurrent.Flow.Subscription.cancel.

Doc from java.util.concurrent.Flow.Subscription.cancel.

Causes the Subscriber to (eventually) stop receiving messages. Implementation is best-effort -- additional messages may be received after invoking this method. A cancelled subscription need not ever receive an onComplete or onError signal.

Annotations

@Override

request back to summary

public void request(long n)

Implements java.util.concurrent.Flow.Subscription.request.

Doc from java.util.concurrent.Flow.Subscription.request.

Adds the given number n of items to the current unfulfilled demand for this subscription. If n is less than or equal to zero, the Subscriber will receive an onError signal with an IllegalArgumentException argument. Otherwise, the Subscriber will receive up to n additional onNext invocations (or fewer if terminated).

Annotations

@Override

public Class HttpBodySubscriberWrapper<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class HttpBodySubscriberWrapper.SubscriptionWrapper

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail