Package com.opencqrs.framework.upcaster

Class AbstractEventDataMarshallingEventUpcaster

java.lang.Object

com.opencqrs.framework.upcaster.AbstractEventDataMarshallingEventUpcaster

All Implemented Interfaces:

EventUpcaster

public abstract class AbstractEventDataMarshallingEventUpcaster
extends Object
implements EventUpcaster

Template implementation of EventUpcaster that uses a delegate EventDataMarshaller to allow subclasses to upcast EventData.metaData() and EventData.payload() as pre-extracted JSON-like Maps.

See Also:

• doUpcast(Event, Map, Map)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	AbstractEventDataMarshallingEventUpcaster.MetaDataAndPayloadResult	Captures upcasted Event.type(), meta-data, and payload.

Nested classes/interfaces inherited from interface com.opencqrs.framework.upcaster.EventUpcaster

EventUpcaster.Result

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractEventDataMarshallingEventUpcaster(EventDataMarshaller eventDataMarshaller)	Constructor for implementations of this.

Method Summary

Modifier and Type	Method	Description
protected abstract Stream<AbstractEventDataMarshallingEventUpcaster.MetaDataAndPayloadResult>	doUpcast(Event event, Map<String,?> metaData, Map<String,?> payload)	Template method to be implemented by subclasses to upcast the given meta-data and payload.
final Stream<EventUpcaster.Result>	upcast(Event event)	Upcasts the given event to a stream of EventUpcaster.Results.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.opencqrs.framework.upcaster.EventUpcaster

canUpcast

Constructor Details

AbstractEventDataMarshallingEventUpcaster

protected AbstractEventDataMarshallingEventUpcaster(EventDataMarshaller eventDataMarshaller)

Constructor for implementations of this.

Parameters:

eventDataMarshaller - the marshaller used to extract EventData from Event.data()

Method Details

upcast

public final Stream<EventUpcaster.Result> upcast(Event event)

Description copied from interface: EventUpcaster

Upcasts the given event to a stream of EventUpcaster.Results. This allows implementations to:

• effectively drop an event by returning an empty stream
• upcast an event to one new event by returning a single element stream
• effectively split up an event by returning a multi element stream

Specified by:

upcast in interface EventUpcaster

Parameters:

event - the event to be upcasted

Returns:

a stream of EventUpcaster.Results carrying the upcasted Event.type() and Event.data()

doUpcast

protected abstract Stream<AbstractEventDataMarshallingEventUpcaster.MetaDataAndPayloadResult> doUpcast(Event event,
 Map<String,?> metaData,
 Map<String,?> payload)

Template method to be implemented by subclasses to upcast the given meta-data and payload.

Parameters:

event - the event from which meta-data and payload have been extracted

metaData - the meta-data

payload - the payload as JSON-like map

Returns:

a stream of AbstractEventDataMarshallingEventUpcaster.MetaDataAndPayloadResult carrying the upcasted representations

See Also:

• EventUpcaster.upcast(Event)