бесконечный поток webflux на запрос - PullRequest
Новая
       35

бесконечный поток webflux на запрос

0 голосов
/ 27 ноября 2018

Я недавно работал над реактивным программированием, чтобы создать приложение для отправки событий с сервера, и у меня есть сценарий использования, который я не знаю, можно ли это сделать с помощью весенней загрузки webflux.Я должен сделать поток значений для каждого запроса, поэтому я создал свою конечную точку следующим образом: 

@GetMapping(value = "/subscribe", produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Flux<Long> Invoke() {
    return Flux.fromStream(Stream.generate(()-> 1)).interval(Duration.ofSeconds(2));
}

Проблема в том, что конечная точка "/ подписка" создается каждый раз, когда она называется потоком, и яне в состоянии обрабатывать большой набор запросов.Примечание. Поток зависит от отправителя (разные потоки для каждого пользователя), поэтому реализация жесткого потока не может быть правильным решением, насколько я знаю.

...