Modifier and Type	Class and Description
private class	BufferingSubscriber.DownstreamSubscription Subscription that is passed to the downstream subscriber.

Field Summary

Modifier and Type	Field and Description
private long	accumulatedBytes The actual accumulated remaining bytes in internalBuffers.
pack-priv static final int	ACTIVE
private final int	bufferSize The amount of data to be accumulate before pushing downstream.
private final Object	buffersLock Must be held when accessing the internal buffers.
pack-priv static final int	CANCELLED
pack-priv static final int	COMPLETE
private final HttpResponse.BodySubscriber<T>	downstreamSubscriber The downstream consumer of the data.
private volatile BufferingSubscriber<T>.DownstreamSubscription	downstreamSubscription The downstream subscription, created lazily.
pack-priv static final int	ERROR
private ArrayList<ByteBuffer>	internalBuffers The internal buffers holding the buffered data.
private volatile int	state
private volatile Flow.Subscription	subscription The subscription, created lazily.
private volatile Throwable	throwable Holds the Throwable from upstream's onError.
pack-priv static final int	UNSUBSCRIBED State of the buffering subscriber: 1) [UNSUBSCRIBED] when initially created 2) [ACTIVE] when subscribed and can receive data 3) [ERROR \| CANCELLED \| COMPLETE] (terminal state)

Access	Constructor and Description
public	BufferingSubscriber(HttpResponse.BodySubscriber<T> downstreamSubscriber, int bufferSize)

Method Summary

Modifier and Type	Method and Description
private List<ByteBuffer>	fromInternalBuffers() Returns a new, unmodifiable, List<ByteBuffer> containing exactly the amount of data as required before pushing downstream.
public CompletionStage<T>	getBody() Implements java.net.http.HttpResponse.BodySubscriber.getBody. Returns a `CompletionStage` which when completed will return the response body object.
private final boolean	hasEnoughAccumulatedBytes() Tells whether, or not, there is at least a sufficient number of bytes accumulated in the internal buffers.
public boolean	needsExecutor() Overrides default jdk.internal.net.http.ResponseSubscribers.TrustedSubscriber.needsExecutor. Returns true if getBody() should be called asynchronously.
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 incomingThrowable) 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.
private static final long	remaining(List<ByteBuffer> buffers) Returns the number of bytes remaining in the given buffers.

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

Field Detail

accumulatedBytes	back to summary
private long accumulatedBytes The actual accumulated remaining bytes in internalBuffers.

ACTIVE	back to summary
pack-priv static final int ACTIVE

bufferSize	back to summary
private final int bufferSize The amount of data to be accumulate before pushing downstream.

buffersLock	back to summary
private final Object buffersLock Must be held when accessing the internal buffers.

CANCELLED	back to summary
pack-priv static final int CANCELLED

COMPLETE	back to summary
pack-priv static final int COMPLETE

downstreamSubscriber	back to summary
private final HttpResponse.BodySubscriber<T> downstreamSubscriber The downstream consumer of the data.

downstreamSubscription	back to summary
private volatile BufferingSubscriber<T>.DownstreamSubscription downstreamSubscription The downstream subscription, created lazily.

ERROR	back to summary
pack-priv static final int ERROR

internalBuffers	back to summary
private ArrayList<ByteBuffer> internalBuffers The internal buffers holding the buffered data.

state	back to summary
private volatile int state

subscription	back to summary
private volatile Flow.Subscription subscription The subscription, created lazily.

throwable	back to summary
private volatile Throwable throwable Holds the Throwable from upstream's onError.

UNSUBSCRIBED	back to summary
pack-priv static final int UNSUBSCRIBED State of the buffering subscriber: 1) [UNSUBSCRIBED] when initially created 2) [ACTIVE] when subscribed and can receive data 3) [ERROR \| CANCELLED \| COMPLETE] (terminal state)

BufferingSubscriber	back to summary
public BufferingSubscriber(HttpResponse.BodySubscriber<T> downstreamSubscriber, int bufferSize)

Method Detail

fromInternalBuffers	back to summary
private List<ByteBuffer> fromInternalBuffers() Returns a new, unmodifiable, List<ByteBuffer> containing exactly the amount of data as required before pushing downstream. The amount of data may be less than required ( bufferSize ), in the case where the subscriber is COMPLETE.

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

hasEnoughAccumulatedBytes	back to summary
private final boolean hasEnoughAccumulatedBytes() Tells whether, or not, there is at least a sufficient number of bytes accumulated in the internal buffers. If the subscriber is COMPLETE, and has some buffered data, then there is always enough ( to pass downstream ).

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

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 incomingThrowable) 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 incomingThrowable)

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

remaining	back to summary
private static final long remaining(List<ByteBuffer> buffers) Returns the number of bytes remaining in the given buffers.

jdk.internal.net.http back to summary

private Class BufferingSubscriber.DownstreamSubscription

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.BufferingSubscriber.DownstreamSubscription

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Subscription that is passed to the downstream subscriber.

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	BufferingSubscriber.DownstreamSubscription.PushDemandedTask

Field Summary

Modifier and Type	Field and Description
private final AtomicBoolean	cancelled
private final Demand	demand
private volatile boolean	illegalArg
private final SequentialScheduler	pushDemandedScheduler

Constructor Summary

Access	Constructor and Description
private	DownstreamSubscription()

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.
pack-priv void	pushDemanded()
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

cancelled	back to summary
private final AtomicBoolean cancelled

demand	back to summary
private final Demand demand

illegalArg	back to summary
private volatile boolean illegalArg

pushDemandedScheduler	back to summary
private final SequentialScheduler pushDemandedScheduler

Constructor Detail

DownstreamSubscription	back to summary
private DownstreamSubscription()

Method Detail

cancel back to summary

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

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

pushDemanded	back to summary
pack-priv void pushDemanded()

request back to summary

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

jdk.internal.net.http back to summary

pack-priv Class BufferingSubscriber.DownstreamSubscription.PushDemandedTask

Class Inheritance

extends CompleteRestartableTask

java.lang.Object
jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask
jdk.internal.net.http.BufferingSubscriber.DownstreamSubscription.PushDemandedTask

Constructor Summary

Access	Constructor and Description
pack-priv	PushDemandedTask()

Method Summary

Modifier and Type	Method and Description
public void	run() Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run. The body of the task.

Inherited from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask:: run

Constructor Detail

PushDemandedTask	back to summary
pack-priv PushDemandedTask()

Method Detail

run	back to summary
public void run() Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run. Doc from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run. The body of the task. Annotations @Override

run

back to summary

public void run()

Implements abstract jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run.

Doc from jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask.run.

The body of the task.

Annotations

@Override

public Class BufferingSubscriber<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class BufferingSubscriber.DownstreamSubscription

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class BufferingSubscriber.DownstreamSubscription.PushDemandedTask

Constructor Summary

Method Summary

Constructor Detail

Method Detail