Method stream_guild_logs

components/scheduler/src/rpc_server.rs:118–132

(
        &self,
        payload: GuildSpecifier,
    )

    }

    async fn stream_guild_logs(
        &self,
        payload: GuildSpecifier,
    ) -> Result<service::SseStream<guild_logger::LogEntry>, StatusCode> {
        let guild_id = payload.guild_id;

        let mut rx = self.log_subscriber.subscribe(guild_id);
        let out = async_stream::try_stream! {
            while let Ok(next) = rx.recv().await{
                yield next;
            }
        };

        Ok(SseStream::new(out))
    }
}