Class CompositeSink

java.lang.Object

com.knezevic.edaf.v3.persistence.sink.CompositeSink

All Implemented Interfaces:

EventSink, AutoCloseable

public final class CompositeSink
extends Object
implements EventSink

Composes multiple sinks into a single sink instance.

Constructor Summary

Constructors

Constructor	Description
CompositeSink(List<EventSink> sinks)

Method Summary

Modifier and Type	Method	Description
CompositeSink	add(EventSink sink)
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

CompositeSink

public CompositeSink(List<EventSink> sinks)

Method Details

add

public CompositeSink add(EventSink sink)

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