import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
})
.doOnNext(message -> list.add(message))
.doOnComplete(() -> log.info("{} was completed!", chatRoom))
})
.doOnNext(message -> list.add(message))
.doOnComplete(() -> log.info("{} was completed!", chatRoom))
- .doOnError(throwalbe -> log.error("{} failed: {}", chatRoom, throwalbe));
+ .doOnError(throwalbe -> log.error("{} failed: {}", chatRoom, throwalbe))
+ .thenMany(Flux.defer(() -> receiveMessages(chatRoom)));