Class CombineRestAction<I1,I2,O>
java.lang.Object
net.dv8tion.jda.internal.requests.restaction.operator.CombineRestAction<I1,I2,O>
- All Implemented Interfaces:
RestAction<O>
-
Constructor Summary
ConstructorsConstructorDescriptionCombineRestAction
(RestAction<I1> action1, RestAction<I2> action2, BiFunction<? super I1, ? super I2, ? extends O> accumulator) -
Method Summary
Modifier and TypeMethodDescriptionaddCheck
(BooleanSupplier checks) Shortcut forsetCheck(() -> getCheck().getAsBoolean() && checks.getAsBoolean())
.complete
(boolean shouldQueue) Blocks the current Thread and awaits the completion of anRestAction.submit()
request.deadline
(long timestamp) Similar toRestAction.timeout(long, TimeUnit)
but schedules a deadline at which the request has to be completed.getCheck()
The current checks for this RestAction.getJDA()
The current JDA instancevoid
Submits a Request for execution.setCheck
(BooleanSupplier checks) Sets the last-second checks before finally executing the http request in the queue.submit
(boolean shouldQueue) Submits a Request for execution and provides aCompletableFuture
representing its completion task.Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface net.dv8tion.jda.api.requests.RestAction
and, and, complete, completeAfter, delay, delay, delay, delay, flatMap, flatMap, map, mapToResult, onErrorFlatMap, onErrorFlatMap, onErrorMap, onErrorMap, onSuccess, queue, queue, queueAfter, queueAfter, queueAfter, queueAfter, queueAfter, queueAfter, submit, submitAfter, submitAfter, timeout, zip
-
Constructor Details
-
CombineRestAction
public CombineRestAction(RestAction<I1> action1, RestAction<I2> action2, BiFunction<? super I1, ? super I2, ? extends O> accumulator)
-
-
Method Details
-
getJDA
Description copied from interface:RestAction
The current JDA instance- Specified by:
getJDA
in interfaceRestAction<I1>
- Returns:
- The corresponding JDA instance
-
setCheck
Description copied from interface:RestAction
Sets the last-second checks before finally executing the http request in the queue.
If the provided supplier evaluates tofalse
or throws an exception this will not be finished. When an exception is thrown from the supplier it will be provided to the failure callback.- Specified by:
setCheck
in interfaceRestAction<I1>
- Parameters:
checks
- The checks to run before executing the request, ornull
to run no checks- Returns:
- The current RestAction for chaining convenience
- See Also:
-
addCheck
Description copied from interface:RestAction
Shortcut forsetCheck(() -> getCheck().getAsBoolean() && checks.getAsBoolean())
.- Specified by:
addCheck
in interfaceRestAction<I1>
- Parameters:
checks
- Other checks to run- Returns:
- The current RestAction for chaining convenience
- See Also:
-
getCheck
Description copied from interface:RestAction
The current checks for this RestAction.- Specified by:
getCheck
in interfaceRestAction<I1>
- Returns:
- The current checks, or null if none were set
- See Also:
-
deadline
Description copied from interface:RestAction
Similar toRestAction.timeout(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
- Specified by:
deadline
in interfaceRestAction<I1>
- Parameters:
timestamp
- Millisecond timestamp at which the request will timeout- Returns:
- The same RestAction with the applied deadline
- See Also:
-
queue
public void queue(@Nullable Consumer<? super O> success, @Nullable Consumer<? super Throwable> failure) Description copied from interface:RestAction
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 }
- Specified by:
queue
in interfaceRestAction<I1>
- 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)- See Also:
-
complete
Description copied from interface:RestAction
Blocks the current Thread and awaits the completion of anRestAction.submit()
request.
Used for synchronous logic.- Specified by:
complete
in interfaceRestAction<I1>
- Parameters:
shouldQueue
- Whether this should automatically handle rate limitations (default true)- Returns:
- The response value
- Throws:
RateLimitedException
- If we were rate limited and theshouldQueue
is false. UseRestAction.complete()
to avoid this Exception.
-
submit
Description copied from interface:RestAction
Submits a Request for execution and provides aCompletableFuture
representing its completion task.
Cancelling the returned Future will result in the cancellation of the Request!- Specified by:
submit
in interfaceRestAction<I1>
- Parameters:
shouldQueue
- Whether the Request should automatically handle rate limitations. (default true)- Returns:
- Never-null
CompletableFuture
task representing the completion promise
-