org.apache.cxf.jaxrs.rx2.server

Class ReactiveIOInvoker

java.lang.Object

org.apache.cxf.service.invoker.AbstractInvoker

org.apache.cxf.jaxrs.JAXRSInvoker

org.apache.cxf.jaxrs.rx2.server.ReactiveIOInvoker

All Implemented Interfaces:

Invoker

public class ReactiveIOInvoker
extends JAXRSInvoker

Constructor Summary

Constructors

Constructor and Description
ReactiveIOInvoker()

Method Summary

Modifier and Type	Method and Description
protected AsyncResponseImpl	checkFutureResponse(Message inMessage, Object result)
protected AsyncResponseImpl	handleFlowable(Message inMessage, <any> f)
protected AsyncResponseImpl	handleObservable(Message inMessage, <any> obs)

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

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

ReactiveIOInvoker

public ReactiveIOInvoker()

Method Detail

checkFutureResponse

protected AsyncResponseImpl checkFutureResponse(Message inMessage,
                                                Object result)

Overrides:

checkFutureResponse in class JAXRSInvoker

handleFlowable

protected AsyncResponseImpl handleFlowable(Message inMessage,
                                           <any> f)

handleObservable

protected AsyncResponseImpl handleObservable(Message inMessage,
                                             <any> obs)