org.apache.cxf.jaxrs.rx2.server

Class StreamingAsyncSubscriber<T>

java.lang.Object

<any>

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

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

Direct Known Subclasses:

JsonStreamingAsyncSubscriber

public class StreamingAsyncSubscriber<T>
extends AbstractAsyncSubscriber<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	StreamingAsyncSubscriber.TimeoutHandlerImpl

Constructor Summary

Constructors

Constructor and Description
StreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar, String openTag, String closeTag, String sep)
StreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar, String openTag, String closeTag, String sep, long pollTimeout)
StreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar, String openTag, String closeTag, String sep, long pollTimeout, long asyncTimeout)

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onNext(T bean)
void	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

StreamingAsyncSubscriber

public StreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar,
                                String openTag,
                                String closeTag,
                                String sep)

StreamingAsyncSubscriber

public StreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar,
                                String openTag,
                                String closeTag,
                                String sep,
                                long pollTimeout)

StreamingAsyncSubscriber

public StreamingAsyncSubscriber(javax.ws.rs.container.AsyncResponse ar,
                                String openTag,
                                String closeTag,
                                String sep,
                                long pollTimeout,
                                long asyncTimeout)

Method Detail

onStart

public void onStart()

Overrides:

onStart in class AbstractAsyncSubscriber<T>

onComplete

public void onComplete()

onNext

public void onNext(T bean)