io.sphere.sdk.client

Class SphereClientUtils

java.lang.Object

io.sphere.sdk.client.SphereClientUtils

public final class SphereClientUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static <T> T	blockingWait(CompletionStage<T> completionStage, Duration duration) Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage.
static <T> T	blockingWait(CompletionStage<T> completionStage, long timeout, TimeUnit unit) Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage.
static <T> T	blockingWait(CompletionStage<T> completionStage, SphereRequest<T> sphereRequest, Duration duration) Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage.
static <T> T	blockingWait(CompletionStage<T> completionStage, SphereRequest<T> sphereRequest, long timeout, TimeUnit unit) Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage.
static <T> List<T>	blockingWaitForEach(List<? extends CompletionStage<T>> list, Duration duration)
static <T> List<T>	blockingWaitForEach(List<? extends CompletionStage<T>> list, long timeout, TimeUnit unit)
static <T> List<T>	blockingWaitForEach(Stream<? extends CompletionStage<T>> stream, Duration duration)
static <T> List<T>	blockingWaitForEach(Stream<? extends CompletionStage<T>> stream, long timeout, TimeUnit unit)
static <S extends CompletionStage<T>,T> Collector<S,?,List<T>>	blockingWaitForEachCollector(Duration duration)
static <S extends CompletionStage<T>,T> Collector<S,?,List<T>>	blockingWaitForEachCollector(long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

blockingWait

public static <T> T blockingWait(CompletionStage<T> completionStage,
                                 SphereRequest<T> sphereRequest,
                                 Duration duration)

Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage. This method should not be used for other CompletionStages since it is throwing SphereExceptions.

Type Parameters:

T - type of the result for the request

Parameters:

completionStage - the future monad to wait for

sphereRequest - the request belonging to the completionStage

duration - the maximum duration to wait for this single request

Returns:

the wrapped value of completionStage

Throws:

SphereTimeoutException - if a timeout occurs

blockingWait

public static <T> T blockingWait(CompletionStage<T> completionStage,
                                 Duration duration)

Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage. This method should not be used for other CompletionStages since it is throwing SphereExceptions.

Type Parameters:

T - type of the result for the request

Parameters:

completionStage - the future monad to wait for

duration - the maximum duration to wait for this single request

Returns:

the wrapped value of completionStage

Throws:

SphereTimeoutException - if a timeout occurs

blockingWait

public static <T> T blockingWait(CompletionStage<T> completionStage,
                                 long timeout,
                                 TimeUnit unit)

Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage. This method should not be used for other CompletionStages since it is throwing SphereExceptions.

Type Parameters:

T - type of the result for the request

Parameters:

completionStage - the future monad to wait for

timeout - the maximum time to wait for this single request

unit - the time unit of the timeout argument

Returns:

the wrapped value of completionStage

Throws:

SphereTimeoutException - if a timeout occurs

blockingWait

public static <T> T blockingWait(CompletionStage<T> completionStage,
                                 SphereRequest<T> sphereRequest,
                                 long timeout,
                                 TimeUnit unit)

Waits with a timeout for RESPONSES of a Composable Commerce client wrapped in a CompletionStage. This method should not be used for other CompletionStages since it is throwing SphereExceptions.

Type Parameters:

T - type of the result for the request

Parameters:

completionStage - the future monad to wait for

sphereRequest - the request belonging to the completionStage

timeout - the maximum time to wait for this single request

unit - the time unit of the timeout argument

Returns:

the wrapped value of completionStage

Throws:

SphereTimeoutException - if a timeout occurs

blockingWaitForEach

public static <T> List<T> blockingWaitForEach(Stream<? extends CompletionStage<T>> stream,
                                              Duration duration)

blockingWaitForEach

public static <T> List<T> blockingWaitForEach(Stream<? extends CompletionStage<T>> stream,
                                              long timeout,
                                              TimeUnit unit)

blockingWaitForEach

public static <T> List<T> blockingWaitForEach(List<? extends CompletionStage<T>> list,
                                              Duration duration)

blockingWaitForEach

public static <T> List<T> blockingWaitForEach(List<? extends CompletionStage<T>> list,
                                              long timeout,
                                              TimeUnit unit)

blockingWaitForEachCollector

public static <S extends CompletionStage<T>,T> Collector<S,?,List<T>> blockingWaitForEachCollector(long timeout,
                                                                                                   TimeUnit unit)

blockingWaitForEachCollector

public static <S extends CompletionStage<T>,T> Collector<S,?,List<T>> blockingWaitForEachCollector(Duration duration)