flux

@RestController
class RestController {
    final var processor = DirectProcessor.create<WaiterCall>().serialize()
    var sink: FluxSink<WaiterCall> = processor.sink()

    @PostMapping(value = ["/addWaiterCall"])
    fun addWaiterCall(@RequestBody waiterCall: WaiterCall) {
        sink.next(waiterCall)
    }

    @GetMapping(value = ["/waiterCalls"],
            produces = [MediaType.TEXT_EVENT_STREAM_VALUE])
    fun prices(): Flux<WaiterCall> {
        return processor
    }
}