org.apache.cxf.jaxrs.rx2.server

Class JsonStreamingAsyncSubscriber<T>

java.lang.Object

<any>

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

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

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

public class JsonStreamingAsyncSubscriber<T>
extends StreamingAsyncSubscriber<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cxf.jaxrs.rx2.server.StreamingAsyncSubscriber

StreamingAsyncSubscriber.TimeoutHandlerImpl

Constructor Summary

Constructors

Constructor and Description
JsonStreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar)
JsonStreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar, long pollTimeout)
JsonStreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar, long pollTimeout, long asyncTimeout)

Method Summary

Methods inherited from class org.apache.cxf.jaxrs.rx2.server.StreamingAsyncSubscriber

onComplete, onNext, onStart

Methods inherited from class org.apache.cxf.jaxrs.rx2.server.AbstractAsyncSubscriber

getAsyncResponse, onError, requestNext, resume, resume, resume

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonStreamingAsyncSubscriber

public JsonStreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar)

JsonStreamingAsyncSubscriber

public JsonStreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar,
                                    long pollTimeout)

JsonStreamingAsyncSubscriber

public JsonStreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar,
                                    long pollTimeout,
                                    long asyncTimeout)