В настоящее время я возвращаю поток изменений клиенту с сервера и хотел бы отправить объект для каждого события. Есть ли способ сделать это?
Объект имеет тип, отличный от класса, используемого для потока изменений. Вот мой текущий код, любая помощь будет высоко оценена заранее.
Измененный поток, который я настроил:
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();
}
Идея состояла бы в том, чтобы возвращать объект также или только объект при каждом новом событии изменения потока