org.apache.cxf.jaxrs.sse

Class SseBroadcasterImpl

java.lang.Object

org.apache.cxf.jaxrs.sse.SseBroadcasterImpl

All Implemented Interfaces:

AutoCloseable, javax.ws.rs.sse.SseBroadcaster

public final class SseBroadcasterImpl
extends Object
implements javax.ws.rs.sse.SseBroadcaster

Constructor Summary

Constructors

Constructor and Description
SseBroadcasterImpl()

Method Summary

Modifier and Type	Method and Description
CompletionStage<?>	broadcast(javax.ws.rs.sse.OutboundSseEvent event)
void	close()
void	onClose(Consumer<javax.ws.rs.sse.SseEventSink> subscriber)
void	onError(BiConsumer<javax.ws.rs.sse.SseEventSink,Throwable> exceptioner)
void	register(javax.ws.rs.sse.SseEventSink sink)

Methods inherited from class java.lang.Object

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

Constructor Detail

SseBroadcasterImpl

public SseBroadcasterImpl()

Method Detail

register

public void register(javax.ws.rs.sse.SseEventSink sink)

Specified by:

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

broadcast

public CompletionStage<?> broadcast(javax.ws.rs.sse.OutboundSseEvent event)

Specified by:

broadcast in interface javax.ws.rs.sse.SseBroadcaster

onClose

public void onClose(Consumer<javax.ws.rs.sse.SseEventSink> subscriber)

Specified by:

onClose in interface javax.ws.rs.sse.SseBroadcaster

onError

public void onError(BiConsumer<javax.ws.rs.sse.SseEventSink,Throwable> exceptioner)

Specified by:

onError in interface javax.ws.rs.sse.SseBroadcaster

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

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