Package com.opencqrs.framework.persistence

Interface EventReader.RawCallback

Enclosing interface:

EventReader

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface EventReader.RawCallback

Callback interface specifying operations to deal with an encapsulated raw Event.

See Also:

• EventReader.consumeRaw(ClientRequestor, BiConsumer)

Method Summary

Modifier and Type	Method	Description
void	upcast(BiConsumer<EventReader.UpcastedCallback,Event> eventConsumer)	Upcasts the encapsulated raw Event and maps resulting event stream to the given consumer.

Method Details

upcast

void upcast(BiConsumer<EventReader.UpcastedCallback,Event> eventConsumer)

Upcasts the encapsulated raw Event and maps resulting event stream to the given consumer.

Parameters:

eventConsumer - a bi-consumer called for each upcasted Event accompanied by an EventReader.UpcastedCallback for further event processing, if needed

See Also:

• EventUpcasters