toEventStream

fun ObjectNode.toEventStream(type: AggregateType, eventType: (String) -> Class<*>?): EventStream

This events query record (EventQueryGateways.kt) of type, each event's body decoded as the class eventType gives its name, an ObjectNode when it gives none.