Class SseBroadcasterImpl

java.lang.Object

org.jboss.resteasy.plugins.providers.sse.SseBroadcasterImpl

All Implemented Interfaces:

jakarta.ws.rs.sse.SseBroadcaster, AutoCloseable

public class SseBroadcasterImpl
extends Object
implements jakarta.ws.rs.sse.SseBroadcaster

Constructor Summary

Constructors

Constructor	Description
SseBroadcasterImpl()

Method Summary

Modifier and Type	Method	Description
CompletionStage<?>	broadcast(jakarta.ws.rs.sse.OutboundSseEvent event)
void	close()
void	close(boolean cascading)
void	onClose(Consumer<jakarta.ws.rs.sse.SseEventSink> onClose)
void	onError(BiConsumer<jakarta.ws.rs.sse.SseEventSink,Throwable> onError)
void	register(jakarta.ws.rs.sse.SseEventSink sseEventSink)

Methods inherited from class java.lang.Object

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

Constructor Details

SseBroadcasterImpl

public SseBroadcasterImpl()

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

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

close

public void close(boolean cascading)

Specified by:

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

onError

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

Specified by:

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

onClose

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

Specified by:

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

register

public void register(jakarta.ws.rs.sse.SseEventSink sseEventSink)

Specified by:

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

broadcast

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

Specified by:

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