org.apache.cxf.jaxrs.sse.client

Class SseEventSourceImpl

java.lang.Object

org.apache.cxf.jaxrs.sse.client.SseEventSourceImpl

All Implemented Interfaces:

AutoCloseable, javax.ws.rs.sse.SseEventSource

public class SseEventSourceImpl
extends Object
implements javax.ws.rs.sse.SseEventSource

SSE Event Source implementation

Nested Class Summary

Nested classes/interfaces inherited from interface javax.ws.rs.sse.SseEventSource

javax.ws.rs.sse.SseEventSource.Builder

Method Summary

Modifier and Type	Method and Description
boolean	close(long timeout, TimeUnit tunit)
boolean	isOpen()
void	open()
void	register(Consumer<javax.ws.rs.sse.InboundSseEvent> onEvent)
void	register(Consumer<javax.ws.rs.sse.InboundSseEvent> onEvent, Consumer<Throwable> onError)
void	register(Consumer<javax.ws.rs.sse.InboundSseEvent> onEvent, Consumer<Throwable> onError, Runnable onComplete)

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.ws.rs.sse.SseEventSource

close, target

Method Detail

register

public void register(Consumer<javax.ws.rs.sse.InboundSseEvent> onEvent)

Specified by:

register in interface javax.ws.rs.sse.SseEventSource

register

public void register(Consumer<javax.ws.rs.sse.InboundSseEvent> onEvent,
                     Consumer<Throwable> onError)

Specified by:

register in interface javax.ws.rs.sse.SseEventSource

register

public void register(Consumer<javax.ws.rs.sse.InboundSseEvent> onEvent,
                     Consumer<Throwable> onError,
                     Runnable onComplete)

Specified by:

register in interface javax.ws.rs.sse.SseEventSource

open

public void open()

Specified by:

open in interface javax.ws.rs.sse.SseEventSource

isOpen

public boolean isOpen()

Specified by:

isOpen in interface javax.ws.rs.sse.SseEventSource

close

public boolean close(long timeout,
                     TimeUnit tunit)

Specified by:

close in interface javax.ws.rs.sse.SseEventSource