Modifier and Type	Class and Description
private class	PullPublisher.Subscription

Modifier and Type	Field and Description
private final CheckedIterable<T>	iterable
private final Throwable	throwable

Access	Constructor and Description
pack-priv	PullPublisher(CheckedIterable<T> iterable, Throwable throwable)
pack-priv	PullPublisher(CheckedIterable<T> iterable)

Modifier and Type	Method and Description
public void	subscribe(Flow.Subscriber<? super T> subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible.

iterable	back to summary
private final CheckedIterable<T> iterable

throwable	back to summary
private final Throwable throwable

PullPublisher	back to summary
pack-priv PullPublisher(CheckedIterable<T> iterable, Throwable throwable)

PullPublisher	back to summary
pack-priv PullPublisher(CheckedIterable<T> iterable)

Method Detail

subscribe back to summary

subscribe	back to summary
public void subscribe(Flow.Subscriber<? super T> subscriber) Implements java.util.concurrent.Flow.Publisher.subscribe. Doc from java.util.concurrent.Flow.Publisher.subscribe. Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's `onError` method is invoked with an `IllegalStateException`. Otherwise, the Subscriber's `onSubscribe` method is invoked with a new `Subscription`. Subscribers may enable receiving items by invoking the `request` method of this Subscription, and may unsubscribe by invoking its `cancel` method. Annotations @Override

public void subscribe(Flow.Subscriber<? super T> subscriber)

Implements java.util.concurrent.Flow.Publisher.subscribe.

Doc from java.util.concurrent.Flow.Publisher.subscribe.

Adds the given Subscriber if possible. If already subscribed, or the attempt to subscribe fails due to policy violations or errors, the Subscriber's onError method is invoked with an IllegalStateException. Otherwise, the Subscriber's onSubscribe method is invoked with a new Subscription. Subscribers may enable receiving items by invoking the request method of this Subscription, and may unsubscribe by invoking its cancel method.

Annotations

@Override

jdk.internal.net.http back to summary

private Class PullPublisher.Subscription

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.PullPublisher.Subscription

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	PullPublisher.Subscription.PullTask

Field Summary

Modifier and Type	Field and Description
private volatile boolean	cancelled
private volatile boolean	completed
private final Demand	demand
private volatile Throwable	error
private final CheckedIterator<T>	iter
pack-priv final SequentialScheduler	pullScheduler
private final Flow.Subscriber<? super T>	subscriber

Constructor Summary

Access	Constructor and Description
pack-priv	Subscription(Flow.Subscriber<? super T> subscriber, CheckedIterator<T> iter, Throwable throwable)

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

cancelled	back to summary
private volatile boolean cancelled

completed	back to summary
private volatile boolean completed

demand	back to summary
private final Demand demand

error	back to summary
private volatile Throwable error

iter	back to summary
private final CheckedIterator<T> iter

pullScheduler	back to summary
pack-priv final SequentialScheduler pullScheduler

subscriber	back to summary
private final Flow.Subscriber<? super T> subscriber

Constructor Detail

Subscription	back to summary
pack-priv Subscription(Flow.Subscriber<? super T> subscriber, CheckedIterator<T> iter, Throwable throwable)

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

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 final Class PullPublisher.Subscription.PullTask

Class Inheritance

extends CompleteRestartableTask

java.lang.Object
jdk.internal.net.http.common.SequentialScheduler.CompleteRestartableTask
jdk.internal.net.http.PullPublisher.Subscription.PullTask

Constructor Summary

Access	Constructor and Description
pack-priv	PullTask()

Method Summary

Modifier and Type	Method and Description
protected 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

PullTask	back to summary
pack-priv PullTask()

Method Detail

run	back to summary
protected 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

protected 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

pack-priv Class PullPublisher<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class PullPublisher.Subscription

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class PullPublisher.Subscription.PullTask

Constructor Summary

Method Summary

Constructor Detail

Method Detail