Class AsyncEventSink

java.lang.Object

com.knezevic.edaf.v3.core.events.AsyncEventSink

All Implemented Interfaces:

EventSink, AutoCloseable

public final class AsyncEventSink
extends Object
implements EventSink

Asynchronous wrapper around one sink with bounded queue and single worker.

The wrapper preserves event order per sink, applies backpressure when the queue is full, and guarantees flush-on-close semantics.

Constructor Summary

Constructors

Constructor	Description
AsyncEventSink(EventSink delegate, String workerName, int queueCapacity)	Creates async wrapper with explicit queue capacity.

Method Summary

Modifier and Type	Method	Description
void	close()
void	onEvent(RunEvent event)	Consumes one event.

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncEventSink

public AsyncEventSink(EventSink delegate,
 String workerName,
 int queueCapacity)

Creates async wrapper with explicit queue capacity.

Method Details

onEvent

public void onEvent(RunEvent event)

Description copied from interface: EventSink

Consumes one event.

Specified by:

onEvent in interface EventSink

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface EventSink