UpdateFeed now immediately starts sending

prevent deletion of .gitignore while generating production
build of fronmtend
This commit is contained in:
2021-05-15 22:58:24 +00:00
parent 7b26672963
commit 27c66f37ab
2 changed files with 3 additions and 1 deletions
+2
View File
@@ -0,0 +1,2 @@
*
!.gitignore
@@ -58,7 +58,7 @@ public class UpdateFeedsService {
} }
private <T> Flux<ServerSentEvent<T>> wrap(Flux<ServerSentEvent<T>> fluxToWrap) { private <T> Flux<ServerSentEvent<T>> wrap(Flux<ServerSentEvent<T>> fluxToWrap) {
return Flux.merge(fluxToWrap, Flux.interval(Duration.ofSeconds(15)).map(aLong -> ServerSentEvent.<T>builder().comment("keep alive").build())); return Flux.merge(fluxToWrap, Flux.interval(Duration.ofSeconds(0), Duration.ofSeconds(15)).map(aLong -> ServerSentEvent.<T>builder().comment("keep alive").build()));
} }
private void storeActiveFeedHandler(String feedId, MessageHandler handler) { private void storeActiveFeedHandler(String feedId, MessageHandler handler) {