Class NonBlockingEventChannel

java.lang.Object

app.dodb.smd.api.event.channel.NonBlockingEventChannel

All Implemented Interfaces:

EventChannel

public class NonBlockingEventChannel
extends Object
implements EventChannel

Method Summary

Modifier and Type	Method	Description
<E extends Event> void	send(EventMessage<E> eventMessage)
void	subscribe(EventChannelListener listener)
static NonBlockingEventChannel	using(ExecutorService executorService)
static NonBlockingEventChannel	usingVirtualThreads()

Methods inherited from class Object

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

Method Details

usingVirtualThreads

public static NonBlockingEventChannel usingVirtualThreads()

using

public static NonBlockingEventChannel using(ExecutorService executorService)

send

public <E extends Event> void send(EventMessage<E> eventMessage)

Specified by:

send in interface EventChannel

subscribe

public void subscribe(EventChannelListener listener)

Specified by:

subscribe in interface EventChannel