org.apache.cxf.jaxrs.reactivestreams.server

Class AbstractSubscriber<T>

java.lang.Object

org.apache.cxf.jaxrs.reactivestreams.server.AbstractSubscriber<T>

All Implemented Interfaces:

org.reactivestreams.Subscriber<T>

Direct Known Subclasses:

StreamingAsyncSubscriber

public abstract class AbstractSubscriber<T>
extends Object
implements org.reactivestreams.Subscriber<T>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSubscriber(javax.ws.rs.container.AsyncResponse ar)

Method Summary

Modifier and Type	Method and Description
protected javax.ws.rs.container.AsyncResponse	getAsyncResponse()
protected org.reactivestreams.Subscription	getSubscription()
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription inSubscription)
protected void	request(long elements)
protected void	requestAll()
protected void	requestNext()
void	resume(List<T> response)
void	resume(StreamingResponse<T> response)
void	resume(T response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractSubscriber

protected AbstractSubscriber(javax.ws.rs.container.AsyncResponse ar)

Method Detail

resume

public void resume(T response)

resume

public void resume(List<T> response)

resume

public void resume(StreamingResponse<T> response)

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription inSubscription)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

getAsyncResponse

protected javax.ws.rs.container.AsyncResponse getAsyncResponse()

getSubscription

protected org.reactivestreams.Subscription getSubscription()

requestNext

protected void requestNext()

requestAll

protected void requestAll()

request

protected final void request(long elements)