如何在反应器中获取先前传递的变量？

Question

我正在制作一个不和谐机器人作为构建在 project-reactor 之上的个人项目？

我需要调用一个函数，该函数需要获取一个在链上进一步传递的变量。

从下面的代码中，我需要传入两个参数。第一个需要来自 MessageCreateEvent 事件的参数，第二个需要来自 getContent 的参数。

我怎么能这样做，我是使用反应器的新手。

    discordClient.getEventDispatcher().on(MessageCreateEvent.class)
            .map(MessageCreateEvent::getMessage)
            .map(Message::getContent)
            .filter(Optional::isPresent)
            .map(o -> o.get())
            .map(this::getCommand)
            .filter(Objects::nonNull)
            .map(msg -> msg.runCommand(null, null))
            .subscribe();

我也试过这个，但我没有看到 runCommand() 被调用。：

    discordClient.getEventDispatcher().on(MessageCreateEvent.class)
            .flatMap(event ->
                Mono.just(event)
                .map(MessageCreateEvent::getMessage)
                .map(Message::getContent)
                .filter(Optional::isPresent)
                .map(o -> o.get())
                .map(this::getCommand)
                .filter(Objects::nonNull)
                .map(msg -> msg.runCommand(event, null))
            )
            .subscribe();

Answer 1

flatMap 很好。该错误可能与您预期的不同。这可能会帮助您弄清楚发生了什么（假设您有一个名为“log”的可用记录器对象）：

Mono.just(event)
    .doOnNext(log::info)
    .map(MessageCreateEvent::getMessage)
    .doOnNext(log::info)

等你的流的每一行。在最后一行你可能想添加：

.doOnEach(s -> log.info("signal: " + s)))

仅供参考，或者对于其他偶然发现这一点的人，从技术上讲， 有一种方法可以使用在链上传递的东西，zipWhen()：

discordClient
    .getEventDispatcher()
    .on(MessageCreateEvent.class)
    .zipWhen(
        event ->
            Mono.just(event)
                .map(MessageCreateEvent::getMessage)
                .map(Message::getContent)
                .filter(Optional::isPresent)
                .map(o -> o.get())
                .map(this::getCommand)
                .filter(Objects::nonNull),
        (event, msg) -> msg.runCommand(event, null))
    .subscribe();

但这不会让你的代码更干净！但对于某些其他情况，它可能会很方便。