Отправка отдельного объекта на каждое событие потока изменений

Question

В настоящее время я возвращаю поток изменений клиенту с сервера и хотел бы отправить объект для каждого события. Есть какой-либо способ сделать это?

Объект имеет тип, отличный от класса, используемого для потока изменений. Вот часть моего текущего кода, любая помощь будет высоко оценена заранее.

Измененный поток, который я настроил:

iesStatusChangeStream = reactiveTemplate.changeStream("iesMasterInfo", changeStreamOptions ,IESMasterInfo.class);

Отображение get, возвращающее поток изменений:

@GetMapping(value="/reactiveStatus",  produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<ChangeStreamEvent<IESMasterInfo>> liveIESMstrInfosStatus(){
    return ndSubEvtProcessor.getIESchangeStreamForStatusTracking();
}

Идея состояла бы в том, чтобы это возвращало объект также или только объект при каждом новом событии changetream