重复消费者 For 循环
Repetitive Consumer For Loop
我正在使用一个带有方法的库,在该方法中,我调用了一个接受事件 class 的方法,并在事件触发时调用了一个消费者。此方法returns无效。我需要在消费者中再次调用该方法,然后在该消费者中再次调用它等等(很多次)。我怎样才能把它放在一个 for 循环中以避免多次输入这个方法?
代码:
ShurikenBot.getInstance().getEventWaiter().waitForEvent(MessageReactionAddEvent.class,
t -> t.getMessageId().equals(m.getId()) && event.getAuthor().getId().equals(t.getMember().getUser().getId())
&& t.getReaction().getReactionEmote().getName().equals("\u25B6"),
t ->
t.getChannel().getMessageById(t.getMessageId()).queue(msg -> {
System.out.println("yes");
// i want to call waitForEvent() again here
msg.editMessage(builder.setTitle("Shuriken Tutorial - Step 2").setImage("https://i.615283.net/u/47794c.jpg").build()).queue();
t.getReaction().removeReaction(t.getUser()).queue();
}));
您可以使用通用事件侦听器创建 State-Machine 而不是使用 EventWaiter。
public class StateMachine extends ListenerAdapter {
private final long messageId;
private final long userId;
private final String emoji;
private int state = 0;
public StateMachine(...) {...}
@Override
public void onMessageReactionAdd(MessageReactionAddEvent event) {
if (event.getMessageIdLong() != messageId) return;
if (event.getUser().getIdLong() != userId) return;
if (!event.getReactionEmote().getName().equals(emoji)) return;
switch (state) {
case 0:
System.out.println("yes");
event.getChannel().editMessageById(messageId, ...).queue();
event.getReaction().removeReaction(event.getUser()).queue();
state = 1;
break;
case 1:
System.out.println("This is the next awaited event");
// do something here...
break;
}
}
}
然后您可以定义一个最终状态,在该状态下您再次删除事件侦听器。
我正在使用一个带有方法的库,在该方法中,我调用了一个接受事件 class 的方法,并在事件触发时调用了一个消费者。此方法returns无效。我需要在消费者中再次调用该方法,然后在该消费者中再次调用它等等(很多次)。我怎样才能把它放在一个 for 循环中以避免多次输入这个方法? 代码:
ShurikenBot.getInstance().getEventWaiter().waitForEvent(MessageReactionAddEvent.class,
t -> t.getMessageId().equals(m.getId()) && event.getAuthor().getId().equals(t.getMember().getUser().getId())
&& t.getReaction().getReactionEmote().getName().equals("\u25B6"),
t ->
t.getChannel().getMessageById(t.getMessageId()).queue(msg -> {
System.out.println("yes");
// i want to call waitForEvent() again here
msg.editMessage(builder.setTitle("Shuriken Tutorial - Step 2").setImage("https://i.615283.net/u/47794c.jpg").build()).queue();
t.getReaction().removeReaction(t.getUser()).queue();
}));
您可以使用通用事件侦听器创建 State-Machine 而不是使用 EventWaiter。
public class StateMachine extends ListenerAdapter {
private final long messageId;
private final long userId;
private final String emoji;
private int state = 0;
public StateMachine(...) {...}
@Override
public void onMessageReactionAdd(MessageReactionAddEvent event) {
if (event.getMessageIdLong() != messageId) return;
if (event.getUser().getIdLong() != userId) return;
if (!event.getReactionEmote().getName().equals(emoji)) return;
switch (state) {
case 0:
System.out.println("yes");
event.getChannel().editMessageById(messageId, ...).queue();
event.getReaction().removeReaction(event.getUser()).queue();
state = 1;
break;
case 1:
System.out.println("This is the next awaited event");
// do something here...
break;
}
}
}
然后您可以定义一个最终状态,在该状态下您再次删除事件侦听器。