CommentSimulator.java 文件源码

@Scheduled(fixedRate = 100)
public void simulateActivity() {
    repository
        .findAll()
        .map(image -> {
            Comment comment = new Comment();
            comment.setImageId(image.getId());
            comment.setComment(
                "Comment #" + counter.getAndIncrement());
            return Mono.just(comment);
        })
        .map(commentController::addComment)
        .subscribe();
}