Package org.openhab.core.io.rest

Class SseBroadcaster<I>

java.lang.Object

org.openhab.core.io.rest.SseBroadcaster<I>

Type Parameters:

I - the type of the SSE event sink specific information

All Implemented Interfaces:

Closeable, AutoCloseable

@NonNullByDefault
public class SseBroadcaster<@NonNull I>
extends Object
implements Closeable

We do not use the SseBroadcaster as it seems registered SseEventSinks are not removed if the peer terminates the connection.

Author:

Markus Rathgeb - Initial contribution

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SseBroadcaster.Listener<I>

Constructor Summary

Constructors

Constructor	Description
SseBroadcaster()

Method Summary

Modifier and Type	Method	Description
@Nullable I	add(javax.ws.rs.sse.SseEventSink sink, @NonNull I info)
void	addListener(SseBroadcaster.Listener<@NonNull I> listener)
void	close()
void	closeAndRemoveIf(Predicate<@NonNull I> predicate)
@Nullable I	getInfo(javax.ws.rs.sse.SseEventSink sink)
Stream<I>	getInfoIf(Predicate<@NonNull I> predicate)
@Nullable I	remove(javax.ws.rs.sse.SseEventSink sink)
void	removeListener(SseBroadcaster.Listener<@NonNull I> listener)
void	send(javax.ws.rs.sse.OutboundSseEvent event)
void	sendIf(javax.ws.rs.sse.OutboundSseEvent event, Predicate<@NonNull I> predicate)

Methods inherited from class java.lang.Object

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

Constructor Details

SseBroadcaster

public SseBroadcaster()

Method Details

addListener

public void addListener(SseBroadcaster.Listener<@NonNull I> listener)

removeListener

public void removeListener(SseBroadcaster.Listener<@NonNull I> listener)

add

public @Nullable I add(javax.ws.rs.sse.SseEventSink sink,
 @NonNull I info)

remove

public @Nullable I remove(javax.ws.rs.sse.SseEventSink sink)

getInfo

public @Nullable I getInfo(javax.ws.rs.sse.SseEventSink sink)

getInfoIf

public Stream<I> getInfoIf(Predicate<@NonNull I> predicate)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

send

public void send(javax.ws.rs.sse.OutboundSseEvent event)

sendIf

public void sendIf(javax.ws.rs.sse.OutboundSseEvent event,
 Predicate<@NonNull I> predicate)

closeAndRemoveIf

public void closeAndRemoveIf(Predicate<@NonNull I> predicate)