org.apache.cxf.jaxrs.rx2.server

Class AbstractAsyncSubscriber<T>

java.lang.Object

<any>

org.apache.cxf.jaxrs.rx2.server.AbstractAsyncSubscriber<T>

Direct Known Subclasses:

StreamingAsyncSubscriber

public abstract class AbstractAsyncSubscriber<T>
extends <any>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected javax.ws.rs.container.AsyncResponse	getAsyncResponse()
void	onError(Throwable t)
void	onStart()
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

AbstractAsyncSubscriber

protected AbstractAsyncSubscriber(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)

getAsyncResponse

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

onStart

public void onStart()

requestNext

protected void requestNext()