Still working on getting announcement system going

This commit is contained in:
NovaFox161
2020-05-15 00:28:29 -05:00
parent 6bba0d3ea2
commit 25ce8488df
@@ -142,7 +142,7 @@ public class DisCalClient {
Mono<Void> startAnnouncement = client.on(ReadyEvent.class)
.doOnNext(ignore -> LogFeed.log(LogObject.forDebug("Ready event hit in announcement start")))
.next()
.flatMapMany(ignore -> Flux.interval(Duration.ofMinutes(5)))
.flatMapMany(ignore -> Flux.interval(Duration.ZERO))
.onBackpressureBuffer()
.flatMap(i -> new AnnouncementThread(client).run())
.then();