org.apache.cxf.jaxrs.reactivestreams.server

Class AbstractReactiveInvoker

java.lang.Object

org.apache.cxf.service.invoker.AbstractInvoker

org.apache.cxf.jaxrs.JAXRSInvoker

org.apache.cxf.jaxrs.reactivestreams.server.AbstractReactiveInvoker

All Implemented Interfaces:

Invoker

Direct Known Subclasses:

ReactiveIOInvoker, ReactorInvoker

public abstract class AbstractReactiveInvoker
extends JAXRSInvoker

Constructor Summary

Constructors

Constructor and Description
AbstractReactiveInvoker()

Method Summary

Modifier and Type	Method and Description
protected Object	handleThrowable(AsyncResponseImpl asyncResponse, Throwable t)
protected boolean	isJsonResponse(Message inMessage)
protected boolean	isStreamingSubscriberUsed(org.reactivestreams.Publisher<?> publisher, javax.ws.rs.container.AsyncResponse asyncResponse, Message inMessage)
boolean	isUseStreamingSubscriberIfPossible()
void	setUseStreamingSubscriberIfPossible(boolean useStreamingSubscriberIfPossible)

Methods inherited from class org.apache.cxf.jaxrs.JAXRSInvoker

checkFutureResponse, getActualServiceObject, getMethodToInvoke, getServiceObject, getTemplateValues, invoke, invoke

Methods inherited from class org.apache.cxf.service.invoker.AbstractInvoker

adjustMethodAndParams, checkSuspendedInvocation, createFault, getMostSpecificMethod, insertExchange, invoke, isJdkDynamicProxy, performInvocation, releaseServiceObject

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractReactiveInvoker

public AbstractReactiveInvoker()

Method Detail

handleThrowable

protected Object handleThrowable(AsyncResponseImpl asyncResponse,
                                 Throwable t)

isJsonResponse

protected boolean isJsonResponse(Message inMessage)

isUseStreamingSubscriberIfPossible

public boolean isUseStreamingSubscriberIfPossible()

isStreamingSubscriberUsed

protected boolean isStreamingSubscriberUsed(org.reactivestreams.Publisher<?> publisher,
                                            javax.ws.rs.container.AsyncResponse asyncResponse,
                                            Message inMessage)

setUseStreamingSubscriberIfPossible

public void setUseStreamingSubscriberIfPossible(boolean useStreamingSubscriberIfPossible)