Interface RestAction<T>
- Type Parameters:
T- The generic response type for this RestAction
- All Known Subinterfaces:
AbstractThreadCreateAction<T,,R> AbstractWebhookMessageAction<T,,R> AccountManager,ApplicationEmojiManager,ApplicationManager,AudioChannelManager<T,,M> AuditableRestAction<T>,AuditLogPaginationAction,AutoCompleteCallbackAction,AutoModRuleManager,BanPaginationAction,CacheRestAction<T>,CategoryManager,CategoryOrderAction,ChannelAction<T>,ChannelManager<T,,M> ChannelOrderAction,CommandCreateAction,CommandEditAction,CommandListUpdateAction,CustomEmojiManager,EntitlementPaginationAction,FluentAuditableRestAction<T,,R> FluentRestAction<T,,R> ForumChannelManager,ForumPostAction,GuildManager,GuildStickerManager,GuildWelcomeScreenManager,IAgeRestrictedChannelManager<T,,M> ICategorizableChannelManager<T,,M> InteractionCallbackAction<T>,InviteAction,IPermissionContainerManager<T,,M> IPositionableChannelManager<T,,M> IPostContainerManager<T,,M> ISlowmodeChannelManager<T,,M> IThreadContainerManager<T,,M> Manager<M>,MediaChannelManager,MemberAction,MessageCreateAction,MessageEditAction,MessageEditCallbackAction,MessagePaginationAction,ModalCallbackAction,NewsChannelManager,OrderAction<T,,M> PaginationAction<T,,M> PermissionOverrideAction,PermOverrideManager,PinnedMessagePaginationAction,PollVotersPaginationAction,ReactionPaginationAction,ReplyCallbackAction,RoleAction,RoleManager,RoleOrderAction,ScheduledEventAction,ScheduledEventManager,ScheduledEventMembersPaginationAction,SelfMemberManager,StageChannelManager,StageInstanceAction,StageInstanceManager,StandardGuildChannelManager<T,,M> StandardGuildMessageChannelManager<T,,M> TemplateManager,TestEntitlementCreateAction,TextChannelManager,ThreadChannelAction,ThreadChannelManager,ThreadChannelPaginationAction,ThreadMemberPaginationAction,VoiceChannelManager,WebhookAction,WebhookManager,WebhookMessageCreateAction<T>,WebhookMessageDeleteAction,WebhookMessageEditAction<T>,WebhookMessageRetrieveAction
- All Known Implementing Classes:
MessageHistory.MessageRetrieveAction,net.dv8tion.jda.internal.requests.RestActionImpl
This is used to offer users the ability to decide how JDA should limit a Request.
Methods that return an instance of RestAction require an additional step to complete the execution. Thus the user needs to append a follow-up method.
A default RestAction is issued with the following operations:
queue(),queue(Consumer),queue(Consumer, Consumer)
The fastest and most simplistic way to execute a RestAction is to queue it.
This method has two optional callback functions, one with the generic type and another with a failure exception.submit(),submit(boolean)
Provides a Future representing the pending request.
An optional parameter of type boolean can be passed to disable automated rate limit handling. (not recommended)complete(),complete(boolean)
Blocking execution building up onsubmit().
This will simply block the thread and return the Request result, or throw an exception.
An optional parameter of type boolean can be passed to disable automated rate limit handling. (not recommended)
queue() operations.
These allow users to provide success and failure callbacks which will be called at a convenient time.
Planning Execution
To schedule a RestAction we provide both queue() and complete() versions that
will be executed by a ScheduledExecutorService after a
specified delay:
queueAfter(long, TimeUnit)
Schedules a call toqueue()with default callbackConsumersto be executed after the specifieddelay.
TheTimeUnitis used to convert the provided long into a delay time.
Example:queueAfter(1, TimeUnit.SECONDS);
will callqueue()1 second later.submitAfter(long, TimeUnit)
This returns aScheduledFuturewhich can be joined into the current Thread usingFuture.get()
The blocking call tosubmitAfter(delay, unit).get()will return the value processed by a call tocomplete()completeAfter(long, TimeUnit)
This operation simply sleeps for the given delay and will callcomplete()once finished sleeping.
All of those operations provide overloads for optional parameters such as a custom
ScheduledExecutorService instead of using the default
global JDA executor. Specifically queueAfter(long, TimeUnit) has overloads
to provide a success and/or failure callback due to the returned ScheduledFuture
not being able to provide the response values of the queue() callbacks.
Using RestActions
The most common way to use a RestAction is not using the returned value.
For instance sending messages usually means you will not require to view the message once
it was sent. Thus we can simply use the asynchronous queue() operation which will
be executed on a rate limit worker thread in the background, without blocking your current thread:
MessageChannel channel = event.getChannel();
RestAction<Message> action = channel.sendMessage("Hello World");
action.queue(); // Execute the rest action asynchronously
Sometimes it is important to access the response value, possibly to modify it later.
Now we have two options to actually access the response value, either using an asynchronous
callback Consumer or the (not recommended) complete() which will block
the current thread until the response has been processed and joins with the current thread.
Example Queue: (recommended)
MessageChannel channel = event.getChannel();
final long time = System.currentTimeMillis();
RestAction<Message> action = channel.sendMessage("Calculating Response Time...");
Consumer<Message> callback = (message) -> {
Message m = message; // ^This is a lambda parameter!^
m.editMessage("Response Time: " + (System.currentTimeMillis() - time) + "ms").queue();
// End with queue() to not block the callback thread!
};
// You can also inline this with the queue parameter: action.queue(m -> m.editMessage(...).queue());
action.queue(callback);
Example Complete:
MessageChannel channel = event.getChannel();
final long time = System.currentTimeMillis();
RestAction<Message> action = channel.sendMessage("Calculating Response Time...");
Message message = action.complete();
message.editMessage("Response Time: " + (System.currentTimeMillis() - time) + "ms").queue();
// End with queue() to not block the callback thread!
Example Planning:
MessageChannel channel = event.getChannel();
RestAction<Message> action = channel.sendMessage("This message will destroy itself in 5 seconds!");
action.queue((message) -> message.delete().queueAfter(5, TimeUnit.SECONDS));
Developer Note: It is generally a good practice to use asynchronous logic because blocking threads requires resources
which can be avoided by using callbacks over blocking operations:
queue(Consumer) > complete()
There is a dedicated wiki page for RestActions that can be useful for learning.
- Since:
- 3.0
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionstatic <E,A, O> RestAction <O> accumulate(Collection<? extends RestAction<? extends E>> actions, Collector<? super E, A, ? extends O> collector) Creates a RestAction instance which accumulates all results of the provided actions.default RestAction<T> addCheck(BooleanSupplier checks) Shortcut forsetCheck(() -> getCheck().getAsBoolean() && checks.getAsBoolean()).static <E> RestAction<List<E>> allOf(Collection<? extends RestAction<? extends E>> actions) Creates a RestAction instance which accumulates all results of the provided actions.static <E> RestAction<List<E>> allOf(RestAction<? extends E> first, RestAction<? extends E>... others) Creates a RestAction instance which accumulates all results of the provided actions.default <U> RestAction<Void> and(RestAction<U> other) Combines this RestAction with the provided action.default <U,O> RestAction <O> and(RestAction<U> other, BiFunction<? super T, ? super U, ? extends O> accumulator) Combines this RestAction with the provided action.default Tcomplete()Blocks the current Thread and awaits the completion of ansubmit()request.complete(boolean shouldQueue) Blocks the current Thread and awaits the completion of ansubmit()request.default TcompleteAfter(long delay, TimeUnit unit) Blocks the current Thread for the specified delay and callscomplete()when delay has been reached.default RestAction<T> deadline(long timestamp) Similar totimeout(long, TimeUnit)but schedules a deadline at which the request has to be completed.default RestAction<T> Intermediate operator that returns a modified RestAction.default RestAction<T> delay(long delay, TimeUnit unit, ScheduledExecutorService scheduler) Intermediate operator that returns a modified RestAction.default RestAction<T> Intermediate operator that returns a modified RestAction.default RestAction<T> delay(Duration duration, ScheduledExecutorService scheduler) Intermediate operator that returns a modified RestAction.default <O> RestAction<O> flatMap(Function<? super T, ? extends RestAction<O>> flatMap) Intermediate operator that returns a modified RestAction.default <O> RestAction<O> Intermediate operator that returns a modified RestAction.default BooleanSuppliergetCheck()The current checks for this RestAction.The default failure callback used when none is provided inqueue(Consumer, Consumer).The default success callback used when none is provided inqueue(Consumer, Consumer)orqueue(Consumer).static longThe default timeout to apply to every RestAction in milliseconds.getJDA()The current JDA instancestatic booleanWhether RestActions will useContextExceptionautomatically to keep track of the caller context.default <O> RestAction<O> Intermediate operator that returns a modified RestAction.default RestAction<Result<T>> Converts the success and failure callbacks into aResult.default RestAction<T> onErrorFlatMap(Function<? super Throwable, ? extends RestAction<? extends T>> map) Supply a fallback value when the RestAction fails for a any reason.default RestAction<T> onErrorFlatMap(Predicate<? super Throwable> condition, Function<? super Throwable, ? extends RestAction<? extends T>> map) Supply a fallback value when the RestAction fails for a specific reason.default RestAction<T> onErrorMap(Function<? super Throwable, ? extends T> map) Supply a fallback value when the RestAction fails for any reason.default RestAction<T> Supply a fallback value when the RestAction fails for a specific reason.default RestAction<T> An intermediate operator that returns a modified RestAction.default voidqueue()Submits a Request for execution.default voidSubmits a Request for execution.voidSubmits a Request for execution.default ScheduledFuture<?> queueAfter(long delay, TimeUnit unit) Schedules a call toqueue()to be executed after the specifieddelay.default ScheduledFuture<?> queueAfter(long delay, TimeUnit unit, ScheduledExecutorService executor) Schedules a call toqueue()to be executed after the specifieddelay.default ScheduledFuture<?> queueAfter(long delay, TimeUnit unit, Consumer<? super T> success) Schedules a call toqueue(java.util.function.Consumer)to be executed after the specifieddelay.default ScheduledFuture<?> queueAfter(long delay, TimeUnit unit, Consumer<? super T> success, ScheduledExecutorService executor) Schedules a call toqueue(java.util.function.Consumer)to be executed after the specifieddelay.default ScheduledFuture<?> queueAfter(long delay, TimeUnit unit, Consumer<? super T> success, Consumer<? super Throwable> failure) Schedules a call toqueue(java.util.function.Consumer, java.util.function.Consumer)to be executed after the specifieddelay.default ScheduledFuture<?> queueAfter(long delay, TimeUnit unit, Consumer<? super T> success, Consumer<? super Throwable> failure, ScheduledExecutorService executor) Schedules a call toqueue(java.util.function.Consumer, java.util.function.Consumer)to be executed after the specifieddelay.setCheck(BooleanSupplier checks) Sets the last-second checks before finally executing the http request in the queue.static voidsetDefaultFailure(Consumer<? super Throwable> callback) The default failure callback used when none is provided inqueue(Consumer, Consumer).static voidsetDefaultSuccess(Consumer<Object> callback) The default success callback used when none is provided inqueue(Consumer, Consumer)orqueue(Consumer).static voidsetDefaultTimeout(long timeout, TimeUnit unit) Default timeout to apply to every RestAction.static voidsetPassContext(boolean enable) If enabled this will pass aContextExceptionas root-cause to all failure consumers.default CompletableFuture<T> submit()Submits a Request for execution and provides aCompletableFuturerepresenting its completion task.submit(boolean shouldQueue) Submits a Request for execution and provides aCompletableFuturerepresenting its completion task.default DelayedCompletableFuture<T> submitAfter(long delay, TimeUnit unit) Schedules a call toqueue()to be executed after the specifieddelay.default DelayedCompletableFuture<T> submitAfter(long delay, TimeUnit unit, ScheduledExecutorService executor) Schedules a call toqueue()to be executed after the specifieddelay.default RestAction<T> Timeout for this RestAction instance.default RestAction<List<T>> zip(RestAction<? extends T> first, RestAction<? extends T>... other) Accumulates this RestAction with the provided actions into aList.
-
Method Details
-
setPassContext
static void setPassContext(boolean enable) If enabled this will pass aContextExceptionas root-cause to all failure consumers.
This might cause performance decrease due to the creation of exceptions for every execution.It is recommended to pass a context consumer as failure manually using
queue(success, ContextException.here(failure))- Parameters:
enable- True, if context should be passed to all failure consumers
-
isPassContext
static boolean isPassContext()Whether RestActions will useContextExceptionautomatically to keep track of the caller context.
If set totruethis can cause performance drops due to the creation of stack-traces on execution.- Returns:
- True, if RestActions will keep track of context automatically
- See Also:
-
setDefaultFailure
The default failure callback used when none is provided inqueue(Consumer, Consumer).- Parameters:
callback- The fallback to use, or null to ignore failures (not recommended)
-
setDefaultSuccess
The default success callback used when none is provided inqueue(Consumer, Consumer)orqueue(Consumer).- Parameters:
callback- The fallback to use, or null to ignore success
-
setDefaultTimeout
Default timeout to apply to every RestAction.
This will use no timeout unless specified otherwise.
If the request doesn't get executed within the specified timeout it will fail.When a RestAction times out, it will fail with a
TimeoutException.- Parameters:
timeout- The default timeout to useunit-Unitfor the timeout value- Throws:
IllegalArgumentException- If the provided unit is null
-
getDefaultTimeout
static long getDefaultTimeout()The default timeout to apply to every RestAction in milliseconds.
If no timeout has been configured, this will return 0.When a RestAction times out, it will fail with a
TimeoutException.- Returns:
- The default timeout in milliseconds, or 0
-
getDefaultFailure
The default failure callback used when none is provided inqueue(Consumer, Consumer).- Returns:
- The fallback consumer
-
getDefaultSuccess
The default success callback used when none is provided inqueue(Consumer, Consumer)orqueue(Consumer).- Returns:
- The fallback consumer
-
allOf
@Nonnull @SafeVarargs @CheckReturnValue static <E> RestAction<List<E>> allOf(@Nonnull RestAction<? extends E> first, @Nonnull RestAction<? extends E>... others) Creates a RestAction instance which accumulates all results of the provided actions.
If one action fails, all others will be cancelled. To handle failures individually instead of cancelling you can usemapToResult().- Type Parameters:
E- The result type- Parameters:
first- The initial RestAction starting pointothers- The remaining actions to accumulate- Returns:
- RestAction - Type:
Listof the results - Throws:
IllegalArgumentException- If null is provided- Since:
- 4.2.1
- See Also:
-
allOf
@Nonnull @CheckReturnValue static <E> RestAction<List<E>> allOf(@Nonnull Collection<? extends RestAction<? extends E>> actions) Creates a RestAction instance which accumulates all results of the provided actions.
If one action fails, all others will be cancelled. To handle failures individually instead of cancelling you can usemapToResult().- Type Parameters:
E- The result type- Parameters:
actions- Non-empty collection of RestActions to accumulate- Returns:
- RestAction - Type:
Listof the results - Throws:
IllegalArgumentException- If null is provided or the collection is empty- Since:
- 4.2.1
- See Also:
-
accumulate
@Nonnull @CheckReturnValue static <E,A, RestAction<O> accumulateO> (@Nonnull Collection<? extends RestAction<? extends E>> actions, @Nonnull Collector<? super E, A, ? extends O> collector) Creates a RestAction instance which accumulates all results of the provided actions.
If one action fails, all others will be cancelled. To handle failures individually instead of cancelling you can usemapToResult().- Type Parameters:
E- The input typeA- The accumulator typeO- The output type- Parameters:
actions- Non-empty collection of RestActions to accumulatecollector- TheCollectorto use- Returns:
- RestAction - Type:
Listof the results - Throws:
IllegalArgumentException- If null is provided or the collection is empty- Since:
- 4.2.1
- See Also:
-
getJDA
The current JDA instance- Returns:
- The corresponding JDA instance
-
setCheck
Sets the last-second checks before finally executing the http request in the queue.
If the provided supplier evaluates tofalseor throws an exception this will not be finished. When an exception is thrown from the supplier it will be provided to the failure callback.- Parameters:
checks- The checks to run before executing the request, ornullto run no checks- Returns:
- The current RestAction for chaining convenience
- See Also:
-
getCheck
The current checks for this RestAction.- Returns:
- The current checks, or null if none were set
- Since:
- 4.2.1
- See Also:
-
addCheck
Shortcut forsetCheck(() -> getCheck().getAsBoolean() && checks.getAsBoolean()).- Parameters:
checks- Other checks to run- Returns:
- The current RestAction for chaining convenience
- Throws:
IllegalArgumentException- If the provided checks are null- Since:
- 4.2.1
- See Also:
-
timeout
Timeout for this RestAction instance.
If the request doesn't get executed within the timeout it will fail.When a RestAction times out, it will fail with a
TimeoutException. This is the same asdeadline(System.currentTimeMillis() + unit.toMillis(timeout)).Example
action.timeout(10, TimeUnit.SECONDS) // 10 seconds from now .queueAfter(20, SECONDS); // request will not be executed within deadline and timeout immediately after 20 seconds- Parameters:
timeout- The timeout to useunit-Unitfor the timeout value- Returns:
- The same RestAction instance with the applied timeout
- Throws:
IllegalArgumentException- If the provided unit is null- See Also:
-
deadline
Similar totimeout(long, TimeUnit)but schedules a deadline at which the request has to be completed.
If the deadline is reached, the request will fail with aTimeoutException.This does not mean that the request will immediately timeout when the deadline is reached. JDA will check the deadline right before executing the request or within intervals in a worker thread. This only means the request will timeout if the deadline has passed.
Example
action.deadline(System.currentTimeMillis() + 10000) // 10 seconds from now .queueAfter(20, SECONDS); // request will not be executed within deadline and timeout immediately after 20 seconds- Parameters:
timestamp- Millisecond timestamp at which the request will timeout- Returns:
- The same RestAction with the applied deadline
- See Also:
-
queue
default void queue()Submits a Request for execution.
Using the default callback functions:setDefaultSuccess(Consumer)andsetDefaultFailure(Consumer)To access the response you can use
queue(java.util.function.Consumer)and to handle failures usequeue(java.util.function.Consumer, java.util.function.Consumer).This method is asynchronous
Example
public static void sendMessage(MessageChannel channel, String content) { // sendMessage returns "MessageAction" which is a specialization for "RestAction<Message>" RestAction<Message> action = channel.sendMessage(content); // call queue() to send the message off to discord. action.queue(); }- Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()- See Also:
-
queue
Submits a Request for execution.
Using the default failure callback function.To handle failures use
queue(java.util.function.Consumer, java.util.function.Consumer).This method is asynchronous
Example
public static void sendPrivateMessage(User user, String content) { // The "<PrivateChannel>" is the response type for the parameter in the success callback RestAction<PrivateChannel> action = user.openPrivateChannel(); // "channel" is the identifier we use to access the channel of the response // this is like the "user" we declared above, just a name for the function parameter action.queue((channel) -> channel.sendMessage(content).queue()); }- Parameters:
success- The success callback that will be called at a convenient time for the API. (can be null)- Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()- See Also:
-
queue
Submits a Request for execution.This method is asynchronous
Example
public static void sendPrivateMessage(JDA jda, String userId, String content) { // Retrieve the user by their id RestAction<User> action = jda.retrieveUserById(userId); action.queue( // Handle success if the user exists (user) -> user.openPrivateChannel().queue( (channel) -> channel.sendMessage(content).queue()), // Handle failure if the user does not exist (or another issue appeared) (error) -> error.printStackTrace() ); // Alternatively use submit() to remove nested callbacks }- Parameters:
success- The success callback that will be called at a convenient time for the API. (can be null to use default)failure- The failure callback that will be called if the Request encounters an exception at its execution point. (can be null to use default)- Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()- See Also:
-
complete
Blocks the current Thread and awaits the completion of ansubmit()request.
Used for synchronous logic.This might throw
RuntimeExceptions- Returns:
- The response value
- Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()IllegalStateException- If used within aqueue(...)callback
-
complete
Blocks the current Thread and awaits the completion of ansubmit()request.
Used for synchronous logic.- Parameters:
shouldQueue- Whether this should automatically handle rate limitations (default true)- Returns:
- The response value
- Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()IllegalStateException- If used within aqueue(...)callbackRateLimitedException- If we were rate limited and theshouldQueueis false. Usecomplete()to avoid this Exception.
-
submit
Submits a Request for execution and provides aCompletableFuturerepresenting its completion task.
Cancelling the returned Future will result in the cancellation of the Request!Example
public static void sendPrivateMessage(JDA jda, String userId, String content) { // Retrieve the user by their id RestAction<User> action = jda.retrieveUserById(userId); action.submit() // CompletableFuture<User> // Handle success if the user exists .thenCompose((user) -> user.openPrivateChannel().submit()) // CompletableFuture<PrivateChannel> .thenCompose((channel) -> channel.sendMessage(content).submit()) // CompletableFuture<Void> .whenComplete((v, error) -> { // Handle failure if the user does not exist (or another issue appeared) if (error != null) error.printStackTrace(); }); }- Returns:
- Never-null
CompletableFuturerepresenting the completion promise - Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()
-
submit
Submits a Request for execution and provides aCompletableFuturerepresenting its completion task.
Cancelling the returned Future will result in the cancellation of the Request!- Parameters:
shouldQueue- Whether the Request should automatically handle rate limitations. (default true)- Returns:
- Never-null
CompletableFuturetask representing the completion promise - Throws:
RejectedExecutionException- If the requester has been shutdown byJDA.shutdown()orJDA.shutdownNow()
-
mapToResult
Converts the success and failure callbacks into aResult.
This means thequeue(Consumer, Consumer)failure consumer will never be used. Instead, all results will be evaluated into a success consumer which provides an instance ofResult.Resultwill either besuccessfulorfailed. This can be useful in combination withallOf(Collection)to handle failed requests individually for each action.Note: You have to handle failures explicitly with this. You should use
Result.onFailure(Consumer),Result.getFailure(), orResult.expect(Predicate)!- Returns:
- RestAction - Type:
Result - Since:
- 4.2.1
-
map
@Nonnull @CheckReturnValue default <O> RestAction<O> map(@Nonnull Function<? super T, ? extends O> map) Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will apply the map function on successful execution.
Example
public RestAction<String> retrieveMemberNickname(Guild guild, String userId) { return guild.retrieveMemberById(userId) .map(Member::getNickname); }- Type Parameters:
O- The target output type- Parameters:
map- The mapping function to apply to the action result- Returns:
- RestAction for the mapped type
- Since:
- 4.1.1
-
onSuccess
An intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction, which will consume the actions result using the given consumer on successful execution. The resulting action continues with the previous result.
Example
Prefer usingpublic RestAction<String> retrieveMemberNickname(Guild guild, String userId) { return guild.retrieveMemberById(userId) .map(Member::getNickname) .onSuccess(System.out::println); }queue(Consumer)instead, if continuation of the action chain is not desired.- Parameters:
consumer- The consuming function to apply to the action result, failures are propagated into the resulting action- Returns:
- RestAction that consumes the action result
- Throws:
IllegalArgumentException- If the consumer is null
-
onErrorMap
@Nonnull @CheckReturnValue default RestAction<T> onErrorMap(@Nonnull Function<? super Throwable, ? extends T> map) Supply a fallback value when the RestAction fails for any reason.This does not modify this instance but returns a new RestAction which will apply the map function on failed execution.
Example
public RestAction<String> sendMessage(User user, String content) { return user.openPrivateChannel() // RestAction<PrivateChannel> .flatMap((channel) -> channel.sendMessage(content)) // RestAction<Message> .map(Message::getContentRaw) // RestAction<String> .onErrorMap(Throwable::getMessage); // RestAction<String> (must be the same as above) }- Parameters:
map- The mapping function which provides the fallback value to use- Returns:
- RestAction with fallback handling
- Throws:
IllegalArgumentException- If the mapping function is null- Since:
- 4.2.0
-
onErrorMap
@Nonnull @CheckReturnValue default RestAction<T> onErrorMap(@Nullable Predicate<? super Throwable> condition, @Nonnull Function<? super Throwable, ? extends T> map) Supply a fallback value when the RestAction fails for a specific reason.This does not modify this instance but returns a new RestAction which will apply the map function on failed execution.
Example
public RestAction<String> sendMessage(User user, String content) { return user.openPrivateChannel() // RestAction<PrivateChannel> .flatMap((channel) -> channel.sendMessage(content)) // RestAction<Message> .map(Message::getContentRaw) // RestAction<String> .onErrorMap(CANNOT_SEND_TO_USER::test, Throwable::getMessage); // RestAction<String> (must be the same as above) }- Parameters:
condition- A condition that must return true to apply this fallbackmap- The mapping function which provides the fallback value to use- Returns:
- RestAction with fallback handling
- Throws:
IllegalArgumentException- If the mapping function is null- Since:
- 4.2.0
- See Also:
-
onErrorFlatMap
@Nonnull @CheckReturnValue default RestAction<T> onErrorFlatMap(@Nonnull Function<? super Throwable, ? extends RestAction<? extends T>> map) Supply a fallback value when the RestAction fails for a any reason.This does not modify this instance but returns a new RestAction which will apply the map function on failed execution.
Example
public RestAction<Message> sendMessage(User user, TextChannel context, String content) { return user.openPrivateChannel() // RestAction<PrivateChannel> .flatMap((channel) -> channel.sendMessage(content)) // RestAction<Message> .onErrorFlatMap( (error) -> context.sendMessage("Failed to send direct message to " + user.getAsMention() + " Reason: " + error) ); // RestAction<Message> (must be the same as above) }- Parameters:
map- The mapping function which provides the fallback action to use- Returns:
- RestAction with fallback handling
- Throws:
IllegalArgumentException- If the mapping function is null- Since:
- 4.2.0
-
onErrorFlatMap
@Nonnull @CheckReturnValue default RestAction<T> onErrorFlatMap(@Nullable Predicate<? super Throwable> condition, @Nonnull Function<? super Throwable, ? extends RestAction<? extends T>> map) Supply a fallback value when the RestAction fails for a specific reason.This does not modify this instance but returns a new RestAction which will apply the map function on failed execution.
Example
public RestAction<Message> sendMessage(User user, TextChannel context, String content) { return user.openPrivateChannel() // RestAction<PrivateChannel> .flatMap((channel) -> channel.sendMessage(content)) // RestAction<Message> .onErrorFlatMap(CANNOT_SEND_TO_USER::test, (error) -> context.sendMessage("Cannot send direct message to " + user.getAsMention()) ); // RestAction<Message> (must be the same as above) }- Parameters:
condition- A condition that must return true to apply this fallbackmap- The mapping function which provides the fallback action to use- Returns:
- RestAction with fallback handling
- Throws:
IllegalArgumentException- If the mapping function is null- Since:
- 4.2.0
- See Also:
-
flatMap
@Nonnull @CheckReturnValue default <O> RestAction<O> flatMap(@Nonnull Function<? super T, ? extends RestAction<O>> flatMap) Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will apply the map function on successful execution. This will compute the result of both RestActions.
The returned RestAction must not be null! To terminate the execution chain on a specific condition you can useflatMap(Predicate, Function).Example
public RestAction<Void> initializeGiveaway(Guild guild, String channelName) { return guild.createTextChannel(channelName) .addPermissionOverride(guild.getPublicRole(), null, EnumSet.of(Permission.MESSAGE_SEND)) // deny write for everyone .addPermissionOverride(guild.getSelfMember(), EnumSet.of(Permission.MESSAGE_SEND), null) // allow for self user .flatMap((channel) -> channel.sendMessage("React to enter giveaway!")) // send message .flatMap((message) -> message.addReaction(REACTION)); // add reaction }- Type Parameters:
O- The target output type- Parameters:
flatMap- The mapping function to apply to the action result, must return a RestAction- Returns:
- RestAction for the mapped type
- Since:
- 4.1.1
-
flatMap
@Nonnull @CheckReturnValue default <O> RestAction<O> flatMap(@Nullable Predicate<? super T> condition, @Nonnull Function<? super T, ? extends RestAction<O>> flatMap) Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will apply the map function on successful execution. This will compute the result of both RestActions.
The provided RestAction must not be null!Example
private static final int MAX_COUNT = 1000; public void updateCount(MessageChannel channel, String messageId, int count) { channel.retrieveMessageById(messageId) // retrieve message for check .map(Message::getContentRaw) // get content of the message .map(Integer::parseInt) // convert it to an int .flatMap( (currentCount) -> currentCount + count <= MAX_COUNT, // Only edit if new count does not exceed maximum (currentCount) -> channel.editMessageById(messageId, String.valueOf(currentCount + count)) // edit message ) .map(Message::getContentRaw) // get content of the message .map(Integer::parseInt) // convert it to an int .queue((newCount) -> System.out.println("Updated count to " + newCount)); }- Type Parameters:
O- The target output type- Parameters:
condition- A condition predicate that decides whether to apply the flat map operator or notflatMap- The mapping function to apply to the action result, must return a RestAction- Returns:
- RestAction for the mapped type
- Since:
- 4.1.1
- See Also:
-
and
@Nonnull @CheckReturnValue default <U,O> RestAction<O> and(@Nonnull RestAction<U> other, @Nonnull BiFunction<? super T, ? super U, ? extends O> accumulator) Combines this RestAction with the provided action.
The result is computed by the providedBiFunction.If one of the actions fails, the other will be cancelled. To handle failures individually instead of cancelling you can use
mapToResult().- Type Parameters:
U- The type of the other actionO- The result type after applying the accumulator function- Parameters:
other- The action to combineaccumulator- BiFunction to compute the result- Returns:
- Combined RestAction
- Throws:
IllegalArgumentException- If null is provided or you tried to combine an action with itself- Since:
- 4.2.1
-
and
Combines this RestAction with the provided action.If one of the actions fails, the other will be cancelled. To handle failures individually instead of cancelling you can use
mapToResult().- Type Parameters:
U- The type of the other action- Parameters:
other- The action to combine- Returns:
- Combined RestAction with empty result
- Throws:
IllegalArgumentException- If null is provided or you tried to combine an action with itself- Since:
- 4.2.1
-
zip
@Nonnull @CheckReturnValue default RestAction<List<T>> zip(@Nonnull RestAction<? extends T> first, @Nonnull RestAction<? extends T>... other) Accumulates this RestAction with the provided actions into aList.If one of the actions fails, the others will be cancelled. To handle failures individually instead of cancelling you can use
mapToResult().- Parameters:
first- The first other action to accumulate into the listother- The other actions to accumulate into the list- Returns:
- Combined RestAction with empty result
- Throws:
IllegalArgumentException- If null is provided or you tried to combine an action with itself- Since:
- 4.2.1
- See Also:
-
delay
Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will delay its result by the provided delay.
Example
public RestAction<Void> selfDestruct(MessageChannel channel, String content) { return channel.sendMessage("The following message will destroy itself in 1 minute!") .delay(Duration.ofSeconds(10)) // edit 10 seconds later .flatMap((it) -> it.editMessage(content)) .delay(Duration.ofMinutes(1)) // delete 1 minute later .flatMap(Message::delete); }- Parameters:
duration- The delay- Returns:
- RestAction with delay
- Since:
- 4.1.1
- See Also:
-
delay
@Nonnull @CheckReturnValue default RestAction<T> delay(@Nonnull Duration duration, @Nullable ScheduledExecutorService scheduler) Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will delay its result by the provided delay.
Example
public RestAction<Void> selfDestruct(MessageChannel channel, String content) { return channel.sendMessage("The following message will destroy itself in 1 minute!") .delay(Duration.ofSeconds(10), scheduler) // edit 10 seconds later .flatMap((it) -> it.editMessage(content)) .delay(Duration.ofMinutes(1), scheduler) // delete 1 minute later .flatMap(Message::delete); }- Parameters:
duration- The delayscheduler- The scheduler to use, null to useJDA.getRateLimitPool()- Returns:
- RestAction with delay
- Since:
- 4.1.1
- See Also:
-
delay
Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will delay its result by the provided delay.
Example
public RestAction<Void> selfDestruct(MessageChannel channel, String content) { return channel.sendMessage("The following message will destroy itself in 1 minute!") .delay(10, SECONDS) // edit 10 seconds later .flatMap((it) -> it.editMessage(content)) .delay(1, MINUTES) // delete 1 minute later .flatMap(Message::delete); }- Parameters:
delay- The delay valueunit- The time unit for the delay value- Returns:
- RestAction with delay
- Since:
- 4.1.1
- See Also:
-
delay
@Nonnull @CheckReturnValue default RestAction<T> delay(long delay, @Nonnull TimeUnit unit, @Nullable ScheduledExecutorService scheduler) Intermediate operator that returns a modified RestAction.This does not modify this instance but returns a new RestAction which will delay its result by the provided delay.
Example
public RestAction<Void> selfDestruct(MessageChannel channel, String content) { return channel.sendMessage("The following message will destroy itself in 1 minute!") .delay(10, SECONDS, scheduler) // edit 10 seconds later .flatMap((it) -> it.editMessage(content)) .delay(1, MINUTES, scheduler) // delete 1 minute later .flatMap(Message::delete); }- Parameters:
delay- The delay valueunit- The time unit for the delay valuescheduler- The scheduler to use, null to useJDA.getRateLimitPool()- Returns:
- RestAction with delay
- Since:
- 4.1.1
- See Also:
-
submitAfter
@Nonnull @CheckReturnValue default DelayedCompletableFuture<T> submitAfter(long delay, @Nonnull TimeUnit unit) Schedules a call toqueue()to be executed after the specifieddelay.
This is an asynchronous operation that will return aCompletableFuturerepresenting the task.Similar to
queueAfter(long, TimeUnit)but does not require callbacks to be passed. Continuations ofCompletableFuturecan be used instead.The global JDA RateLimit
ScheduledExecutorServiceis used for this operation.
You can provide your own Executor usingsubmitAfter(long, java.util.concurrent.TimeUnit, java.util.concurrent.ScheduledExecutorService)!- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelay- Returns:
DelayedCompletableFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit isnull
-
submitAfter
@Nonnull @CheckReturnValue default DelayedCompletableFuture<T> submitAfter(long delay, @Nonnull TimeUnit unit, @Nullable ScheduledExecutorService executor) Schedules a call toqueue()to be executed after the specifieddelay.
This is an asynchronous operation that will return aCompletableFuturerepresenting the task.Similar to
queueAfter(long, TimeUnit)but does not require callbacks to be passed. Continuations ofCompletableFuturecan be used instead.The specified
ScheduledExecutorServiceis used for this operation.- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelayexecutor- TheScheduledExecutorServicethat should be used to schedule this operation, or null to use the default- Returns:
DelayedCompletableFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit isnull
-
completeAfter
Blocks the current Thread for the specified delay and callscomplete()when delay has been reached.
If the specified delay is negative this action will execute immediately. (see:TimeUnit.sleep(long))- Parameters:
delay- The delay after which to execute a call tocomplete()unit- TheTimeUnitwhich should be used (this will useunit.sleep(delay))- Returns:
- The response value
- Throws:
IllegalArgumentException- If the specifiedTimeUnitisnullRuntimeException- If the sleep operation is interrupted
-
queueAfter
Schedules a call toqueue()to be executed after the specifieddelay.
This is an asynchronous operation that will return aScheduledFuturerepresenting the task.This operation gives no access to the response value.
UsequeueAfter(long, java.util.concurrent.TimeUnit, java.util.function.Consumer)to access the success consumer forqueue(java.util.function.Consumer)!The global JDA
ScheduledExecutorServiceis used for this operation.
You can provide your own Executor withqueueAfter(long, java.util.concurrent.TimeUnit, java.util.concurrent.ScheduledExecutorService)- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelay- Returns:
ScheduledFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit isnull
-
queueAfter
@Nonnull default ScheduledFuture<?> queueAfter(long delay, @Nonnull TimeUnit unit, @Nullable Consumer<? super T> success) Schedules a call toqueue(java.util.function.Consumer)to be executed after the specifieddelay.
This is an asynchronous operation that will return aScheduledFuturerepresenting the task.This operation gives no access to the failure callback.
UsequeueAfter(long, java.util.concurrent.TimeUnit, java.util.function.Consumer, java.util.function.Consumer)to access the failure consumer forqueue(java.util.function.Consumer, java.util.function.Consumer)!The global JDA
ScheduledExecutorServiceis used for this operation.
You can provide your own Executor withqueueAfter(long, java.util.concurrent.TimeUnit, java.util.function.Consumer, java.util.concurrent.ScheduledExecutorService)- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelaysuccess- The successConsumerthat should be called once thequeue(java.util.function.Consumer)operation completes successfully.- Returns:
ScheduledFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit isnull
-
queueAfter
@Nonnull default ScheduledFuture<?> queueAfter(long delay, @Nonnull TimeUnit unit, @Nullable Consumer<? super T> success, @Nullable Consumer<? super Throwable> failure) Schedules a call toqueue(java.util.function.Consumer, java.util.function.Consumer)to be executed after the specifieddelay.
This is an asynchronous operation that will return aScheduledFuturerepresenting the task.The global JDA
ScheduledExecutorServiceis used for this operation.
You provide your own Executor withqueueAfter(long, java.util.concurrent.TimeUnit, java.util.function.Consumer, java.util.function.Consumer, java.util.concurrent.ScheduledExecutorService)- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelaysuccess- The successConsumerthat should be called once thequeue(java.util.function.Consumer, java.util.function.Consumer)operation completes successfully.failure- The failureConsumerthat should be called in case of an error of thequeue(java.util.function.Consumer, java.util.function.Consumer)operation.- Returns:
ScheduledFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit isnull- See Also:
-
queueAfter
@Nonnull default ScheduledFuture<?> queueAfter(long delay, @Nonnull TimeUnit unit, @Nullable ScheduledExecutorService executor) Schedules a call toqueue()to be executed after the specifieddelay.
This is an asynchronous operation that will return aScheduledFuturerepresenting the task.This operation gives no access to the response value.
UsequeueAfter(long, java.util.concurrent.TimeUnit, java.util.function.Consumer)to access the success consumer forqueue(java.util.function.Consumer)!The specified
ScheduledExecutorServiceis used for this operation.- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelayexecutor- The Non-nullScheduledExecutorServicethat should be used to schedule this operation- Returns:
ScheduledFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit or ScheduledExecutorService isnull
-
queueAfter
@Nonnull default ScheduledFuture<?> queueAfter(long delay, @Nonnull TimeUnit unit, @Nullable Consumer<? super T> success, @Nullable ScheduledExecutorService executor) Schedules a call toqueue(java.util.function.Consumer)to be executed after the specifieddelay.
This is an asynchronous operation that will return aScheduledFuturerepresenting the task.This operation gives no access to the failure callback.
UsequeueAfter(long, java.util.concurrent.TimeUnit, java.util.function.Consumer, java.util.function.Consumer)to access the failure consumer forqueue(java.util.function.Consumer, java.util.function.Consumer)!The specified
ScheduledExecutorServiceis used for this operation.- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelaysuccess- The successConsumerthat should be called once thequeue(java.util.function.Consumer)operation completes successfully.executor- The Non-nullScheduledExecutorServicethat should be used to schedule this operation- Returns:
ScheduledFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit or ScheduledExecutorService isnull
-
queueAfter
@Nonnull default ScheduledFuture<?> queueAfter(long delay, @Nonnull TimeUnit unit, @Nullable Consumer<? super T> success, @Nullable Consumer<? super Throwable> failure, @Nullable ScheduledExecutorService executor) Schedules a call toqueue(java.util.function.Consumer, java.util.function.Consumer)to be executed after the specifieddelay.
This is an asynchronous operation that will return aScheduledFuturerepresenting the task.The specified
ScheduledExecutorServiceis used for this operation.- Parameters:
delay- The delay after which this computation should be executed, negative to execute immediatelyunit- TheTimeUnitto convert the specifieddelaysuccess- The successConsumerthat should be called once thequeue(java.util.function.Consumer, java.util.function.Consumer)operation completes successfully.failure- The failureConsumerthat should be called in case of an error of thequeue(java.util.function.Consumer, java.util.function.Consumer)operation.executor- The Non-nullScheduledExecutorServicethat should be used to schedule this operation- Returns:
ScheduledFuturerepresenting the delayed operation- Throws:
IllegalArgumentException- If the provided TimeUnit or ScheduledExecutorService isnull- See Also:
-