Modifier and Type	Class and Description
pack-priv static class	LineSubscriberAdapter.LineSubscription

Modifier and Type	Field and Description
private final CompletableFuture<R>	cf
private final Charset	charset
private volatile LineSubscriberAdapter.LineSubscription	downstream
private final String	eol
private final Function<? super S, ? extends R>	finisher
private final AtomicBoolean	subscribed
private final S	subscriber

Access	Constructor and Description
private	LineSubscriberAdapter(S subscriber, Function<? super S, ? extends R> finisher, Charset charset, String eol)

Method Summary

Modifier and Type	Method and Description
public static <S extends Flow.Subscriber<? super String>, R> LineSubscriberAdapter<S, R>	create(S subscriber, Function<? super S, ? extends R> finisher, Charset charset, String eol)
public CompletionStage<R>	getBody() Implements java.net.http.HttpResponse.BodySubscriber.getBody. Returns a `CompletionStage` which when completed will return the response body object.
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 the exception 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> the item item) Implements java.util.concurrent.Flow.Subscriber.onNext. Method invoked with a Subscription's next item.
public void	onSubscribe(Flow.Subscription a new subscription subscription) Implements java.util.concurrent.Flow.Subscriber.onSubscribe. Method invoked prior to invoking any other Subscriber methods for the given Subscription.

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

cf	back to summary
private final CompletableFuture<R> cf

charset	back to summary
private final Charset charset

downstream	back to summary
private volatile LineSubscriberAdapter.LineSubscription downstream

eol	back to summary
private final String eol

finisher	back to summary
private final Function<? super S, ? extends R> finisher

subscribed	back to summary
private final AtomicBoolean subscribed

subscriber	back to summary
private final S subscriber

LineSubscriberAdapter	back to summary
private LineSubscriberAdapter(S subscriber, Function<? super S, ? extends R> finisher, Charset charset, String eol)

Method Detail

create	back to summary
public static <S extends Flow.Subscriber<? super String>, R> LineSubscriberAdapter<S, R> create(S subscriber, Function<? super S, ? extends R> finisher, Charset charset, String eol)

getBody back to summary

getBody	back to summary
public CompletionStage<R> 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`. Returns:CompletionStage<R> a CompletionStage for the response body Annotations @Override

public CompletionStage<R> 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.

Returns:CompletionStage<R>

a CompletionStage for the response body

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 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. Parameters throwable:Throwable the exception 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.

Parameters

throwable:Throwable: the exception

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. Parameters item:List<ByteBuffer> the item 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.

Parameters

item:List<ByteBuffer>: the item

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. Parameters subscription:Flow.Subscription a new subscription 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.

Parameters

subscription:Flow.Subscription: a new subscription

Annotations

@Override

jdk.internal.net.http back to summary

pack-priv final Class LineSubscriberAdapter.LineSubscription

Class Inheritance

extends Object
implements Subscription

java.lang.Object
jdk.internal.net.http.LineSubscriberAdapter.LineSubscription

All Implemented Interfaces

java.util.concurrent.Flow.Subscription

Field Summary

Modifier and Type	Field and Description
private final CharBuffer	buffer
private final StringBuilder	builder
private volatile boolean	cancelled
pack-priv final CompletableFuture<?>	cf
private final char[]	chars
private volatile boolean	completed
pack-priv final CharsetDecoder	decoder
private final AtomicLong	demanded
pack-priv final Demand	downstreamDemand
private final AtomicReference<Throwable>	errorRef
private final ByteBuffer	leftover
pack-priv final String	newline
private String	nextLine
pack-priv final ConcurrentLinkedDeque<ByteBuffer>	queue
pack-priv final SequentialScheduler	scheduler
pack-priv final Flow.Subscriber<? super String>	upstream
pack-priv final Flow.Subscription	upstreamSubscription

Constructor Summary

Access	Constructor and Description
private	LineSubscription(Flow.Subscription s, CharsetDecoder dec, String separator, Flow.Subscriber<? super String> subscriber, CompletableFuture<?> completion)

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 static LineSubscriberAdapter.LineSubscription	create(Flow.Subscription s, Charset charset, String lineSeparator, Flow.Subscriber<? super String> upstream, CompletableFuture<?> cf)
private static int	endOfLine(StringBuilder b, String eol, boolean endOfInput)
private boolean	isUnderFlow(ByteBuffer in, CharBuffer out, boolean endOfInput)
private void	loop()
private static String	nextLine(StringBuilder b, String eol, boolean endOfInput)
private String	nextLine()
public void	request(long the increment of demand; a value of `Long.MAX_VALUE` may be considered as effectively unbounded n) Implements java.util.concurrent.Flow.Subscription.request. Adds the given number `n` of items to the current unfulfilled demand for this subscription.
public void	signalComplete()
public void	signalError(Throwable error)
public void	submit(List<ByteBuffer> list)
private static String	take(StringBuilder b, int start, int end)

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

Field Detail

buffer	back to summary
private final CharBuffer buffer

builder	back to summary
private final StringBuilder builder

cancelled	back to summary
private volatile boolean cancelled

cf	back to summary
pack-priv final CompletableFuture<?> cf

chars	back to summary
private final char[] chars

completed	back to summary
private volatile boolean completed

decoder	back to summary
pack-priv final CharsetDecoder decoder

demanded	back to summary
private final AtomicLong demanded

downstreamDemand	back to summary
pack-priv final Demand downstreamDemand

errorRef	back to summary
private final AtomicReference<Throwable> errorRef

leftover	back to summary
private final ByteBuffer leftover

newline	back to summary
pack-priv final String newline

nextLine	back to summary
private String nextLine

queue	back to summary
pack-priv final ConcurrentLinkedDeque<ByteBuffer> queue

scheduler	back to summary
pack-priv final SequentialScheduler scheduler

upstream	back to summary
pack-priv final Flow.Subscriber<? super String> upstream

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

Constructor Detail

LineSubscription	back to summary
private LineSubscription(Flow.Subscription s, CharsetDecoder dec, String separator, Flow.Subscriber<? super String> subscriber, CompletableFuture<?> completion)

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

create	back to summary
pack-priv static LineSubscriberAdapter.LineSubscription create(Flow.Subscription s, Charset charset, String lineSeparator, Flow.Subscriber<? super String> upstream, CompletableFuture<?> cf)

endOfLine	back to summary
private static int endOfLine(StringBuilder b, String eol, boolean endOfInput)

isUnderFlow	back to summary
private boolean isUnderFlow(ByteBuffer in, CharBuffer out, boolean endOfInput) throws CharacterCodingException

loop	back to summary
private void loop()

nextLine	back to summary
private static String nextLine(StringBuilder b, String eol, boolean endOfInput)

nextLine	back to summary
private String nextLine() throws CharacterCodingException

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). Parameters n:long the increment of demand; a value of `Long.MAX_VALUE` may be considered as effectively unbounded 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).

Parameters

n:long: the increment of demand; a value of Long.MAX_VALUE may be considered as effectively unbounded

Annotations

@Override

signalComplete	back to summary
public void signalComplete()

signalError	back to summary
public void signalError(Throwable error)

submit	back to summary
public void submit(List<ByteBuffer> list)

take	back to summary
private static String take(StringBuilder b, int start, int end)

public final Class LineSubscriberAdapter<S extends Flow.Subscriber<? super String>, R>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class LineSubscriberAdapter.LineSubscription

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail