From 13fee5ea02dfffb086f2d4e94ea5284c12a7d79f Mon Sep 17 00:00:00 2001 From: NovaFox161 Date: Fri, 15 May 2020 00:35:24 -0500 Subject: [PATCH] Still working on getting announcement system going --- .../org/dreamexposure/discal/client/DisCalClient.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/client/src/main/java/org/dreamexposure/discal/client/DisCalClient.java b/client/src/main/java/org/dreamexposure/discal/client/DisCalClient.java index d8871316..47aeb900 100644 --- a/client/src/main/java/org/dreamexposure/discal/client/DisCalClient.java +++ b/client/src/main/java/org/dreamexposure/discal/client/DisCalClient.java @@ -139,13 +139,21 @@ public class DisCalClient { .flatMap(MessageCreateListener::handle) .then(); - Mono startAnnouncement = client.on(ReadyEvent.class) + Mono startAnnouncement = Flux.interval(Duration.ZERO) + .onBackpressureBuffer() + .doOnNext(ignore -> LogFeed.log(LogObject.forDebug("Tick"))) + .flatMap(ignore -> new AnnouncementThread(client).run()) + .then(); + + /* + client.on(ReadyEvent.class) .doOnNext(ignore -> LogFeed.log(LogObject.forDebug("Ready event hit in announcement start"))) .next() .flatMapMany(ignore -> Flux.interval(Duration.ZERO)) .onBackpressureBuffer() .flatMap(i -> new AnnouncementThread(client).run()) .then(); + */ return Mono.when(onReady, onTextChannelDelete, onRoleDelete, onCommand, startAnnouncement); }).block();