public abstract class AsyncResponseConsumer extends Object
Modifier and Type | Field and Description |
---|---|
protected ResteasyAsynchronousResponse |
asyncResponse |
protected Map<Class<?>,Object> |
contextDataMap |
protected SynchronousDispatcher |
dispatcher |
protected boolean |
isComplete |
protected ResourceMethodInvoker |
method |
Constructor and Description |
---|
AsyncResponseConsumer(ResourceMethodInvoker method) |
Modifier and Type | Method and Description |
---|---|
protected Type |
adaptGenericType(Type unwrappedType) |
void |
complete(Throwable t) |
protected BuiltResponse |
createResponse(Object entity,
HttpRequest httpRequest) |
protected void |
doComplete() |
protected void |
internalResume(Object entity,
Consumer<Throwable> onComplete) |
protected void |
internalResume(Throwable t,
Consumer<Throwable> onComplete) |
static AsyncResponseConsumer |
makeAsyncResponseConsumer(ResourceMethodInvoker method,
AsyncResponseProvider<?> asyncResponseProvider) |
static AsyncResponseConsumer |
makeAsyncResponseConsumer(ResourceMethodInvoker method,
AsyncStreamProvider<?> asyncStreamProvider) |
protected void |
sendBuiltResponse(BuiltResponse builtResponse,
HttpRequest httpRequest,
HttpResponse httpResponse,
Consumer<Throwable> onComplete) |
protected abstract boolean |
sendHeaders() |
abstract void |
subscribe(Object rtn) |
protected ResourceMethodInvoker method
protected SynchronousDispatcher dispatcher
protected ResteasyAsynchronousResponse asyncResponse
protected boolean isComplete
public AsyncResponseConsumer(ResourceMethodInvoker method)
public static AsyncResponseConsumer makeAsyncResponseConsumer(ResourceMethodInvoker method, AsyncResponseProvider<?> asyncResponseProvider)
public static AsyncResponseConsumer makeAsyncResponseConsumer(ResourceMethodInvoker method, AsyncStreamProvider<?> asyncStreamProvider)
protected void doComplete()
public final void complete(Throwable t)
protected void sendBuiltResponse(BuiltResponse builtResponse, HttpRequest httpRequest, HttpResponse httpResponse, Consumer<Throwable> onComplete) throws IOException
IOException
protected abstract boolean sendHeaders()
protected BuiltResponse createResponse(Object entity, HttpRequest httpRequest)
public abstract void subscribe(Object rtn)
Copyright © 2018 JBoss by Red Hat. All rights reserved.