Top Fields Constructors Methods

org.eclipse.jetty.reactive.client.internal

public abstract Class AbstractEventPublisher<T>

Class Inheritance

extends AbstractSinglePublisher<T>

java.lang.Object
org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher
org.eclipse.jetty.reactive.client.internal.AbstractEventPublisher

Known Direct Subclasses

org.eclipse.jetty.reactive.client.internal.RequestEventPublisher, org.eclipse.jetty.reactive.client.internal.ResponseEventPublisher

Imports

org.eclipse.jetty.util.MathUtils, org.eclipse.jetty.util.thread.AutoLock, org.reactivestreams.Subscriber

Field Summary

Modifier and Type	Field and Description
private long	demand
private Throwable	failure
private boolean	initial
private boolean	terminated

Constructor Summary

Access	Constructor and Description
public	AbstractEventPublisher()

Method Summary

Modifier and Type	Method and Description
protected void	emit(T event)
protected void	fail(Throwable failure)
protected void	onRequest(Subscriber<? super T> subscriber, long n) Implements abstract org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher.onRequest.
protected void	succeed()

Inherited from org.eclipse.jetty.reactive.client.internal.AbstractSinglePublisher:: cancel emitOnComplete emitOnError emitOnNext lock onFailure request subscribe subscriber toString

Field Detail

demand	back to summary
private long demand

failure	back to summary
private Throwable failure

initial	back to summary
private boolean initial

terminated	back to summary
private boolean terminated

Constructor Detail

AbstractEventPublisher	back to summary
public AbstractEventPublisher()

Method Detail

emit	back to summary
protected void emit(T event)

fail	back to summary
protected void fail(Throwable failure)

onRequest

back to summary

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

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

Annotations

@Override

succeed	back to summary
protected void succeed()