Still working on getting announcement system going

This commit is contained in:
NovaFox161
2020-05-15 00:35:24 -05:00
parent 25ce8488df
commit 13fee5ea02

View File

@@ -139,13 +139,21 @@ public class DisCalClient {
.flatMap(MessageCreateListener::handle)
.then();
Mono<Void> startAnnouncement = client.on(ReadyEvent.class)
Mono<Void> 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();