Still working on getting announcement system going

This commit is contained in:
NovaFox161
2020-05-15 00:16:23 -05:00
parent c95780c047
commit 6bba0d3ea2

View File

@@ -140,6 +140,7 @@ public class DisCalClient {
.then();
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)))
.onBackpressureBuffer()