Top Inners Fields Constructors Methods
org.eclipse.jetty.reactive.client.internal

public Class QueuedSinglePublisher<T>

extends AbstractSinglePublisher<T>
Class Inheritance
Known Direct Subclasses
org.eclipse.jetty.reactive.client.internal.ResponseListenerProcessor.ContentPublisher
Imports
java.util.ArrayDeque, .Queue, java.util.concurrent.CompletionException, org.eclipse.jetty.util.MathUtils, org.eclipse.jetty.util.thread.AutoLock, org.reactivestreams.Subscriber, org.slf4j.Logger, .LoggerFactory

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
QueuedSinglePublisher.Complete

private class
QueuedSinglePublisher.Failure

private static interface
QueuedSinglePublisher.Terminal<T>

Field Summary

Modifier and TypeField and Description
private boolean
active

private long
demand

private final Queue<Object>
items

private static final Logger
logger

Hides org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher.logger.

private boolean
stalled

private Throwable
terminated

Constructor Summary

AccessConstructor and Description
public
QueuedSinglePublisher()

Method Summary

Modifier and TypeMethod and Description
public void
complete()

public boolean
fail(Throwable failure)

public boolean
hasDemand()

private boolean
isTerminal(Object item)

public void
offer(T item)

protected void
onNext(Subscriber<? super T> subscriber, T item)

protected void
onRequest(Subscriber<? super T> subscriber, long n)

Implements abstract org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher.onRequest.

private void
proceed(Subscriber<? super T> subscriber)

private boolean
process(Object item)

protected void
tryProduce(Runnable producer)

Inherited from org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher:
cancelemitOnCompleteemitOnErroremitOnNextlockonFailurerequestsubscribesubscribertoString

Field Detail

activeback to summary
private boolean active
demandback to summary
private long demand
itemsback to summary
private final Queue<Object> items
loggerback to summary
private static final Logger logger

Hides org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher.logger.

stalledback to summary
private boolean stalled
terminatedback to summary
private Throwable terminated

Constructor Detail

QueuedSinglePublisherback to summary
public QueuedSinglePublisher()

Method Detail

completeback to summary
public void complete()
failback to summary
public boolean fail(Throwable failure)
hasDemandback to summary
public boolean hasDemand()
isTerminalback to summary
private boolean isTerminal(Object item)
offerback to summary
public void offer(T item)
onNextback to summary
protected void onNext(Subscriber<? super T> subscriber, T item)
onRequestback to summary
protected void onRequest(Subscriber<? super T> subscriber, long n)

Implements abstract org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher.onRequest.

Annotations
@Override
proceedback to summary
private void proceed(Subscriber<? super T> subscriber)
processback to summary
private boolean process(Object item)
tryProduceback to summary
protected void tryProduce(Runnable producer)
org.eclipse.jetty.reactive.client.internal back to summary

private Class QueuedSinglePublisher.Complete

extends Object
implements QueuedSinglePublisher.Terminal<T>
Class Inheritance
  • java.lang.Object
  • org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Complete
All Implemented Interfaces
org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Terminal

Constructor Summary

AccessConstructor and Description
private
Complete()

Method Summary

Modifier and TypeMethod and Description
public void
notify(Subscriber<? super T> subscriber)

Implements org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Terminal.notify.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

Completeback to summary
private Complete()

Method Detail

notifyback to summary
public void notify(Subscriber<? super T> subscriber)

Implements org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Terminal.notify.

Annotations
@Override
org.eclipse.jetty.reactive.client.internal back to summary

private Class QueuedSinglePublisher.Failure

extends Object
implements QueuedSinglePublisher.Terminal<T>
Class Inheritance
  • java.lang.Object
  • org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Failure
All Implemented Interfaces
org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Terminal

Field Summary

Modifier and TypeField and Description
private final Throwable
failure

Constructor Summary

AccessConstructor and Description
private
Failure(Throwable failure)

Method Summary

Modifier and TypeMethod and Description
public void
notify(Subscriber<? super T> subscriber)

Implements org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Terminal.notify.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

failureback to summary
private final Throwable failure

Constructor Detail

Failureback to summary
private Failure(Throwable failure)

Method Detail

notifyback to summary
public void notify(Subscriber<? super T> subscriber)

Implements org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Terminal.notify.

Annotations
@Override
org.eclipse.jetty.reactive.client.internal back to summary

private Interface QueuedSinglePublisher.Terminal<T>

Known Direct Implementers
org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Complete, org.eclipse.jetty.reactive.client.internal.QueuedSinglePublisher.Failure
Annotations
@FunctionalInterface

Method Summary

Modifier and TypeMethod and Description
public void
notify(Subscriber<? super T> subscriber)

Method Detail

notifyback to summary
public void notify(Subscriber<? super T> subscriber)